Function Composition для serverless-оркестрации в AWS и Azure

{ "Comment": "Обработка заказа",
  "StartAt": "ValidateOrder",
  "States": {
    "ValidateOrder": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-east-1:123:function:validate-order",
      "Next": "CheckInventory",
      "Retry": [
        {
          "ErrorEquals": ["Lambda.ServiceException"],
          "MaxAttempts": 3
        }
      ],
      "Catch": [
        {
          "ErrorEquals": ["ValidationError"],
          "Next": "NotifyInvalidOrder"
        }
      ]
    },
    "CheckInventory": {
      "Type": "Parallel",
      "Branches": [
        {
          "StartAt": "ReserveItems",
          "States": {
            "ReserveItems": {
              "Type": "Task",
              "Resource": "arn:...:reserve-items",
              "End": true
            }
          }
        },
        {
          "StartAt": "CalculateShipping",
          "States": {
            "CalculateShipping": {
              "Type": "Task",
              "Resource": "arn:...:calc-shipping",
              "End": true
            }
          }
        }
      ],
      "Next": "ProcessPayment"
    },
    "ProcessPayment": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke.waitForTaskToken",
      "Parameters": {
        "FunctionName": "arn:...:process-payment",
        "Payload": {
          "taskToken.$": "$$.Task.Token",
          "orderId.$": "$.orderId"
        }
      },
      "Next": "FulfillOrder",
      "TimeoutSeconds": 300
    },
    "FulfillOrder": {
      "Type": "Task",
      "Resource": "arn:...:fulfill-order",
      "End": true
    },
    "NotifyInvalidOrder": {
      "Type": "Task",
      "Resource": "arn:...:notify-invalid",
      "End": true
    }
  }
}

.waitForTaskToken позволяет Step Functions ждать callback от внешней системы (например, платёжного шлюза) без постоянного опроса. Платёжный шлюз вызывает SendTaskSuccess с токеном, когда транзакция завершена.

Terraform для Step Functions

resource "aws_sfn_state_machine" "order_processing" {
  name = "order-processing"
  role_arn = aws_iam_role.sfn_role.arn
  definition = templatefile("${path.module}/state_machine.json", {
    validate_lambda_arn = aws_lambda_function.validate_order.arn
    reserve_lambda_arn = aws_lambda_function.reserve_items.arn
    payment_lambda_arn = aws_lambda_function.process_payment.arn
    fulfill_lambda_arn = aws_lambda_function.fulfill_order.arn
  })

  logging_configuration {
    log_destination = "${aws_cloudwatch_log_group.sfn.arn}:*"
    include_execution_data = true
    level = "ERROR"
  }

  tracing_configuration {
    enabled = true # X-Ray tracing
  }
}

Сравнение: AWS Step Functions vs Azure Durable Functions

Ваш выбор зависит от экосистемы: если вы на AWS — Step Functions, если на Azure — Durable Functions. В случае мультиоблака можно использовать единый оркестратор на базе Temporal или Camunda, но это выходит за рамки serverless.

Azure Durable Functions: альтернатива

.NET / Node.js / Python оркестратор на базе Azure Functions:

import azure.durable_functions as df

def orchestrator_function(context: df.DurableOrchestrationContext):
    parallel_tasks = [
        context.call_activity("ReserveItems", context.get_input()),
        context.call_activity("CalculateShipping", context.get_input())
    ]
    results = yield context.task_all(parallel_tasks)
    approval = yield context.wait_for_external_event("ApprovalReceived")
    if approval:
        return (yield context.call_activity("FulfillOrder", context.get_input()))
    else:
        return (yield context.call_activity("CancelOrder", context.get_input()))

main = df.Orchestrator.create(orchestrator_function)

Durable Functions используют Azure Storage для хранения состояния. Оркестратор может ждать внешнего события неограниченно долго.

Как обрабатывать ошибки в оркестрации?

В распределённых процессах нет встроенных транзакций. Паттерн Saga — компенсирующие действия при отказе:

"ProcessPayment": {
  "Type": "Task",
  "Resource": "...",
  "Catch": [{
    "ErrorEquals": ["PaymentFailed"],
    "Next": "CompensateReservation"
  }]
},
"CompensateReservation": {
  "Type": "Task",
  "Resource": "arn:...:release-reservation",
  "Next": "NotifyPaymentFailed"
}

Каждый шаг, который нужно откатить при ошибке, имеет компенсирующую функцию. Видимость обеспечивается через CloudWatch Metrics и X-Ray для Step Functions, а для Durable Functions — Application Insights.

Express vs Standard Workflows

Standard Workflows в 2500 раз дороже Express Workflows за переход, но поддерживают длительные процессы с полным аудитом. Для проектов с нагрузкой более 10 000 вызовов в день выгоднее Express.

Что входит в работу

• Архитектурная документация с описанием workflow и всех функций.
• Код оркестратора и лямбда-функций (или Azure Functions) в вашем репозитории.
• Инфраструктурный код (Terraform / Bicep) для развёртывания.
• Настроенный мониторинг и алерты (CloudWatch / Application Insights).
• Доступ к репозиторию и инструкции по развёртыванию.
• Обучение вашей команды работе с оркестратором.

Процесс работы и сроки

1. Проектирование state machine + ASL описание — 2–3 дня.
2. Lambda функции для каждого шага — 3–7 дней.
3. Step Functions state machine + IAM — 2–3 дня.
4. Обработка ошибок + компенсации — 2–3 дня.
5. Мониторинг + алерты + тестирование — 2–3 дня.

Свяжитесь с нами для консультации — закажите реализацию Function Composition под ключ. Пишите, и получите коммерческое предложение с детальным планом в течение одного дня. Наш опыт подтверждают 30+ успешных внедрений в финтехе, e-commerce и логистике. Получите консультацию — просто напишите нам.