הרכבת פונקציות לאורקסטרציה ללא שרת

{ "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
    }
  }
}

{ "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} } } מאפשר ל-Step Functions להמתין ל-callback ממערכת חיצונית (למשל, שער תשלומים) ללא polling. שער התשלומים קורא ל-.waitForTaskToken עם ה-token כאשר העסקה מסתיימת.

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 לעומת Azure Durable Functions

הבחירה שלכם תלויה במערכת האקולוגית שלכם: אם אתם על AWS — Step Functions; אם על Azure — Durable Functions. בתרחישי multi-cloud, אפשר להשתמש באורכסטרטור אחיד כמו 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"
}

לכל שלב שדורש rollback בשגיאה יש פונקציית פיצוי. נראות מסופקת דרך CloudWatch Metrics ו-X-Ray עבור Step Functions, ו-Application Insights עבור Durable Functions.

Express לעומת Standard Workflows

Standard Workflows יקרים פי 2500 לכל מעבר מאשר Express Workflows, אבל תומכים בתהליכים ארוכי טווח עם ביקורת מלאה. לפרויקטים עם יותר מ-10,000 קריאות ביום, Express משתלם יותר.

מה כלול

• תיעוד ארכיטקטוני המתאר את זרימת העבודה וכל הפונקציות.
• קוד אורכסטרטור ו-Lambda (או Azure Functions) במאגר שלכם.
• קוד תשתית (Terraform / Bicep) לפריסה.
• ניטור והתראות מוגדרים (CloudWatch / Application Insights).
• גישה למאגר והוראות פריסה.
• הדרכה לצוות שלכם על עבודה עם האורכסטרטור.

תהליך ולוחות זמנים

1. עיצוב State machine + תיאור ASL — 2-3 ימים.
2. פונקציות Lambda לכל שלב — 3-7 ימים.
3. State machine של Step Functions + IAM — 2-3 ימים.
4. טיפול בשגיאות + פיצויים — 2-3 ימים.
5. ניטור + התראות + בדיקות — 2-3 ימים.

צרו קשר לייעוץ — הזמינו הטמעת Function Composition במפתח פתוח. כתבו לנו וקבלו הצעה מסחרית עם תוכנית מפורטת תוך יום אחד. הניסיון שלנו מגובה ביותר מ-30 פריסות מוצלחות בפינטק, מסחר אלקטרוני ולוגיסטיקה. קבלו ייעוץ — פשוט פנו אלינו.