### 如何在 AWS Lambda (Python) 中与 AWS Step Functions 集成 AWS Lambda 和 AWS Step Functions 的集成可以通过定义状态机(State Machine)实现复杂的工作流程自动化。Step Functions 提供了一种可视化的方式来协调多个 AWS 服务作为无服务器工作流的一部分[^1]。 #### 创建 State Machine 并调用 Lambda 函数 要将 AWS Lambda 与 AWS Step Functions 集成，首先需要创建一个状态机。这个状态机会通过 JSON 定义一系列步骤，每一步都可以是一个 Lambda 调用或其他 AWS 服务的操作。以下是基本的步骤： - **定义状态机**: 使用 Amazon States Language 编写 JSON 文件来描述状态机的行为。 - **配置权限**: 确保 Step Functions 对目标 Lambda 函数有执行权限。这通常涉及修改 IAM 角色以允许 `states:StartExecution` 动作[^2]。 下面是一段简单的 Python Lambda 函数代码示例，用于接收来自 Step Functions 的输入并返回结果: ```python import json def lambda_handler(event, context): # 打印接收到的事件数据 print(f"Received event: {json.dumps(event)}") # 假设我们有一个名为 'input_key' 的键存在于传入的数据中 input_value = event.get('input_key', None) if not input_value: return { "statusCode": 400, "body": json.dumps({"error": "'input_key' missing from input"}) } output_message = f"Processed value: {input_value}" return { "statusCode": 200, "body": json.dumps({ "message": output_message, "event": event }) } ``` 此函数会打印日志消息，并基于输入参数构建响应对象[^3]。 #### 设置 Step Functions 工作流 假设我们要设计一个两步的状态机，其中第一步调用了上面展示的那个 Lambda 函数，第二步则可能再次调用另一个不同的 Lambda 或者结束整个过程。这里提供了一个简化版的例子： ```json { "Comment": "A simple example of a state machine invoking two lambdas.", "StartAt": "FirstLambda", "States": { "FirstLambda": { "Type": "Task", "Resource": "arn:aws:lambda:<region>:<account-id>:function:MyFirstFunction", "Next": "SecondState" }, "SecondState": { "Type": "Pass", "Result": {"key":"value"}, "End": true } } } ``` 在这个例子中，“FirstLambda”节点代表的是第一个被执行的任务——即调用指定 ARN 下的一个 Lambda 函数；而 “SecondState” 则仅仅传递了一些固定的结果给最终输出[^4]。 #### 关于成本考量 当考虑长期运行此类架构时，应该注意到每次触发都会计入请求计费模型之中。此外还有内存消耗及时长等因素影响总费用。因此优化单次处理逻辑减少不必要的循环是非常重要的[^2]。 ---