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 та логістиці. Отримайте консультацію — просто напишіть нам.