AWS中SQS-Lambda-Step Function架构下如何实现单消息串行处理？

你遇到的核心问题是：Lambda仅负责启动Step Function执行就立即结束，导致Lambda快速释放并发槽位，SQS会继续推送下一条消息，进而触发新的Step Function并行运行。以下是几种可行的解决办法：

方法1：让Lambda等待Step Function执行完成后再结束 #

在Lambda代码中，启动Step Function执行后不要立即返回，而是等待Step Function执行完成再结束函数。这样Lambda的执行时长会覆盖Step Function的运行时间，结合预留并发1的设置，就能保证同一时间只有一个Step Function在运行。

示例代码（Python）：

import boto3
import time

sf_client = boto3.client('stepfunctions')

def lambda_handler(event, context):
    # 启动Step Function执行
    execution_resp = sf_client.start_execution(
        stateMachineArn='你的状态机ARN',
        input=event['Records'][0]['body']
    )
    execution_arn = execution_resp['executionArn']
    
    # 轮询等待执行完成
    while True:
        execution_status = sf_client.describe_execution(executionArn=execution_arn)
        status = execution_status['status']
        if status in ['SUCCEEDED', 'FAILED', 'ABORTED']:
            break
        time.sleep(5)  # 每5秒轮询一次
    
    return {
        'statusCode': 200,
        'body': f"Step Function执行完成，状态：{status}"
    }

注意事项：

• 必须将Lambda的超时时间设置为大于等于Step Function的最长执行时间，避免Lambda超时导致SQS重新推送消息。
• 轮询间隔不要设置过短，避免API调用次数过多产生额外费用。

方法2：设置Step Functions状态机的并发限制 #

直接在Step Functions层面控制最大并发执行数，即使Lambda触发多个执行请求，Step Functions会自动将超出限制的请求排队，串行执行。

操作步骤：

1. 登录AWS控制台，进入Step Functions服务，打开目标状态机。
2. 点击右上角的编辑 → 设置。
3. 在并发限制部分，勾选启用并发限制，并将最大并发执行数设置为1。
4. 保存设置。

这种方法无需修改Lambda代码，是最简单的全局控制方式。

方法3：调整SQS与Lambda的触发逻辑（进阶） #

如果不想让Lambda等待Step Function，也可以通过SQS的可见性窗口+Lambda异步回调的方式实现：

• Lambda启动Step Function时，将SQS消息的ReceiptHandle传递给Step Function。
• Step Function执行完成后，通过一个额外的Lambda任务删除SQS消息。
• 将SQS的可见性窗口设置为Step Function的最长执行时间，确保在执行期间消息不会被重新推送。

这种方式适合Step Function执行时间很长，不想占用Lambda并发的场景，但实现复杂度较高。

内容的提问来源于stack exchange，提问作者khaldrogo 91