如何跟踪100个并发AWS Lambda执行状态并在全部成功时发邮件？

针对你提到的场景——遍历100个项目推送SQS触发Lambda（并发限制50），需等待所有Lambda执行成功后发送邮件，以下是对你两种思路的分析及优化建议：

思路一：数据库状态追踪的优劣势 #

这种方案可行，但存在几个需要优化的点：

• 竞态风险：多个Lambda同时更新数据库并检查全量状态时，可能出现竞态条件（比如两个Lambda同时检查到只剩最后一条未完成，都触发邮件），需要用数据库原子操作（如DynamoDB的UpdateItem带条件判断，或RDS的事务）避免重复触发。
• 资源冗余：前99个Lambda的全量状态检查都是无效操作，只有最后完成的那个Lambda的检查才会触发邮件，造成不必要的数据库查询开销。
• 故障处理复杂：如果有Lambda执行失败，需要额外处理状态回滚、重试标记等逻辑，否则会一直无法触发邮件。

思路二：Step Functions Map状态的最优性 #

这是最适合AWS生态的方案，完全匹配你的需求：

• 原生并行管控：Map状态支持根据输入的项目列表自动生成并行子任务，可直接设置并发数（比如你需要的50），无需依赖SQS做消息分发，架构更简洁。
• 自动等待全量完成：Map状态会默认等待所有子Lambda执行成功后才进入下一个状态，无需自己编写状态检查逻辑；如果有子任务失败，还可配置重试策略、容错规则（如跳过失败项或终止流程）。
• 内置状态追踪：Step Functions控制台会自动记录每个子任务的执行状态，方便排查问题，无需额外维护数据库。
• 无缝集成邮件发送：在Map状态之后，直接添加调用AWS SES（简单邮件服务）的任务，或触发专门发邮件的Lambda，形成完整闭环。

替代方案（若需保留SQS架构） #

如果因为存量系统限制必须保留SQS触发Lambda的模式，可以用CloudWatch Events配合DynamoDB计数器优化：

• 给Lambda的InvokeSuccess事件创建CloudWatch规则，触发一个汇总Lambda。
• 汇总Lambda使用DynamoDB的原子递增操作更新计数器，当计数器达到100时，触发邮件并重置计数器，避免全量查询的开销。

通用注意事项 #

• 无论采用哪种方案，都要配置失败告警：用CloudWatch Alarm监控Lambda失败次数或Step Functions的失败状态，避免因个别任务失败导致邮件无法触发的情况。
• 若使用Step Functions，注意配置合适的超时时间，避免因个别Lambda执行超时导致整个状态机挂起。

内容的提问来源于stack exchange，提问作者SUNNY R K