0Pricing
Serverless Backend with AWS Lambda & API Gateway · 课时

编排复杂工作流

使用 Step Functions 构建包含条件逻辑、并行执行和错误处理的复杂无服务器工作流

编排复杂工作流 是 CoddyKit 上的免费 Serverless Backend with AWS Lambda & API Gateway 课时。 这是第 3 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Serverless Backend with AWS Lambda & API Gateway 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Serverless Backend with AWS Lambda & API Gateway 课程共包含 4 节课。

本课时的部分内容尚未翻译,以英文显示。

Orchestrating Complex Workflows

Welcome! In this lesson, we'll dive into building sophisticated serverless workflows with AWS Step Functions.

We'll explore how to add decision-making, run tasks concurrently, and make your workflows resilient to errors.

Decision Making with Choice

The Choice state is your workflow's "if/else" statement. It allows your state machine to make decisions based on the input it receives.

  • Each choice rule has a condition (e.g., input value equals "X").
  • If a condition is met, the workflow transitions to a specified state.
  • A default state handles cases where no conditions match.

Choice State Example

Here's how a Choice state looks in your Step Functions definition. It checks an orderStatus field to decide the next step.

{  "StartAt": "CheckOrderStatus",  "States": {    "CheckOrderStatus": {      "Type": "Choice",      "Choices": [        {          "Variable": "$.orderStatus",          "StringEquals": "PENDING",          "Next": "ProcessPendingOrder"        },        {          "Variable": "$.orderStatus",          "StringEquals": "SHIPPED",          "Next": "NotifyShipping"        }      ],      "Default": "HandleUnknownStatus"    },    "ProcessPendingOrder": {      "Type": "Task",      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:processPending",      "End": true    },    "NotifyShipping": {      "Type": "Task",      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:notifyShipping",      "End": true    },    "HandleUnknownStatus": {      "Type": "Fail",      "Cause": "Unknown order status",      "Error": "InvalidOrderStatus"    }  }}

Running Tasks in Parallel

The Parallel state allows you to execute multiple branches of your workflow concurrently. This is great for tasks that don't depend on each other and can run at the same time.

  • Each branch runs independently.
  • The Parallel state waits for all branches to complete.
  • Outputs from all branches are combined into an array.

Parallel State Example

This Parallel state simultaneously processes an order and updates inventory, then combines their results.

{  "StartAt": "ProcessOrderAndInventory",  "States": {    "ProcessOrderAndInventory": {      "Type": "Parallel",      "Branches": [        {          "StartAt": "ProcessOrder",          "States": {            "ProcessOrder": {              "Type": "Task",              "Resource": "arn:aws:lambda:us-east-1:123456789012:function:processOrder",              "End": true            }          }        },        {          "StartAt": "UpdateInventory",          "States": {            "UpdateInventory": {              "Type": "Task",              "Resource": "arn:aws:lambda:us-east-1:123456789012:function:updateInventory",              "End": true            }          }        }      ],      "Next": "CombineResults"    },    "CombineResults": {      "Type": "Pass",      "End": true    }  }}

Handling Errors Gracefully

Things can go wrong! Step Functions provides robust error handling with the Catch field. You can specify what errors to catch and which state to transition to when an error occurs.

  • Errors are identified by their type (e.g., States.TaskFailed).
  • You can catch specific errors or a generic States.ALL.
  • The ResultPath specifies where the error output is placed.

Catch State Example

Here, if the ProcessPayment task fails, it's caught and the workflow moves to the RefundOrder state.

{  "StartAt": "ProcessPayment",  "States": {    "ProcessPayment": {      "Type": "Task",      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:processPayment",      "Catch": [        {          "ErrorEquals": [ "States.TaskFailed", "PaymentFailure" ],          "Next": "RefundOrder",          "ResultPath": "$.errorInfo"        }      ],      "Next": "CompleteOrder"    },    "RefundOrder": {      "Type": "Task",      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:refundOrder",      "End": true    },    "CompleteOrder": {      "Type": "Pass",      "End": true    }  }}

Retrying Failed Tasks

For transient errors (like network timeouts), it's often better to retry the task a few times before failing. The Retry field lets you define retry policies.

  • Specify which errors to retry.
  • Configure IntervalSeconds, MaxAttempts, and BackoffRate.
  • Exponential backoff (BackoffRate > 1) is highly recommended.

Retry State Example

This task will retry up to 3 times with exponential backoff if a Timeout or NetworkError occurs.

{  "StartAt": "CallExternalService",  "States": {    "CallExternalService": {      "Type": "Task",      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:callExternalService",      "Retry": [        {          "ErrorEquals": [ "States.Timeout", "NetworkError" ],          "IntervalSeconds": 2,          "MaxAttempts": 3,          "BackoffRate": 1.5        }      ],      "End": true    }  }}

Orchestrating It All

The real power of Step Functions comes from combining these states. You can build highly sophisticated workflows by nesting Parallel states within Choices, adding Retries to Tasks, and Catching errors at various levels.

This allows you to model almost any business process, making your serverless applications robust and adaptable.

Workflow Logic Check

Consider a workflow that needs to:

  1. Check if a user is premium.
  2. If premium, send a personalized email AND update their loyalty points simultaneously.
  3. If not premium, send a standard email.
  4. Handle any email sending failures by logging them without stopping the workflow.

Which Step Functions states would be essential to implement this logic?

Recap: Complex Workflows

You've mastered advanced Step Functions concepts!

  • We used Choice states for conditional logic.
  • We leveraged Parallel states for concurrent execution.
  • We implemented robust error handling with Catch blocks.
  • And we learned about Retry policies for transient failures.

These tools allow you to build incredibly powerful and resilient event-driven serverless applications!

常见问题解答

「编排复杂工作流」课时是免费的吗?

是的 — 「编排复杂工作流」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Serverless Backend with AWS Lambda & API Gateway 课程的其余内容,请升级到 CoddyKit PRO。 Serverless Backend with AWS Lambda & API Gateway 课程共包含 4 节课。

「编排复杂工作流」这节课中我会学到什么?

使用 Step Functions 构建包含条件逻辑、并行执行和错误处理的复杂无服务器工作流 你通过在浏览器中直接运行的动手代码来练习 Serverless Backend with AWS Lambda & API Gateway,全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Serverless Backend with AWS Lambda & API Gateway 需要有经验吗?

无需任何先前经验。CoddyKit 上的 Serverless Backend with AWS Lambda & API Gateway 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 3 节课,共 4 节。

「编排复杂工作流」课时需要多长时间?

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。

我能在这节 Serverless Backend with AWS Lambda & API Gateway 课中编写并运行代码吗?

能。每节 Serverless Backend with AWS Lambda & API Gateway 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

  1. AWS Step Functions 简介
  2. 构建状态机
  3. 编排复杂工作流
  4. 状态机中的错误处理与重试
← 返回 Serverless Backend with AWS Lambda & API Gateway