如何在接收所有数据中心的SQS消息后触发Lambda函数

方案1：状态跟踪+延迟重试机制 #

这是最直接的实现方式，核心是跟踪每个数据中心的完成状态，结合延迟重试覆盖最大时间差窗口：

• 每个数据中心完成消息写入后，向一个控制SQS队列发送一条带DC标识的"完成通知"消息。
• 配置Lambda函数触发该控制队列的消息，Lambda执行逻辑：
  1. 用DynamoDB作为状态存储，收到通知后更新对应DC的状态为"已完成"。
  2. 查询DynamoDB中4个DC的状态，若全部完成则执行目标业务逻辑，随后清理状态记录。
  3. 若未全部完成，将当前状态检查任务重新发送到带10分钟延迟的SQS队列，等待延迟结束后再次触发Lambda检查状态。
• 给状态记录设置TTL（比如24小时），避免无效数据堆积。

方案2：定时扫描校验 #

适合对实时性要求不高的场景：

• 每个数据中心完成写入后，将自身完成状态写入DynamoDB（或其他持久化存储），同时标记任务的唯一批次ID。
• 用CloudWatch Events创建定时规则，每隔10分钟触发一次Lambda函数。
• Lambda执行逻辑：
  1. 扫描DynamoDB中未处理的任务批次，检查对应4个DC的状态是否全部完成。
  2. 对已完成的批次执行目标业务逻辑，并标记该批次为"已处理"。
  3. 跳过已处理或未满足条件的批次。

方案3：Step Functions 聚合回调 #

利用AWS Step Functions的状态机管理等待与聚合逻辑：

• 创建Step Functions状态机，启动时初始化包含4个DC的待完成列表。
• 每个数据中心完成写入后，调用Step Functions的SendTaskSuccess API，传递自身DC标识。
• 状态机设置"等待回调"状态，收到每个DC的回调后从待完成列表中移除对应项。
• 当待完成列表为空时，触发Lambda执行目标业务逻辑；若超过10分钟仍未收齐所有回调，状态机可进入超时处理（比如告警或重试）。

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