AWS自定义事件单次触发Lambda传递文件创建统计方案咨询

单函数场景实现 #

直接绑定S3对象创建事件到Lambda B的方案天然存在缺陷，核心原因是S3事件为逐对象触发，没有任务终态聚合能力，必然导致B被重复调用。可按以下逻辑实现，保证B仅触发1次、且拿到全量文件统计信息：

• 首先给Lambda A配置5分钟运行超时，直接在Lambda控制台基本配置项中修改即可。
• 引入任务状态追踪：每次Lambda A被触发时生成唯一任务ID，在DynamoDB中创建对应任务记录，字段包含task_id、expected_file_count=5、actual_file_count=0、task_start_time、status=running、b_triggered=false，A生成的所有文件统一使用该task_id作为S3路径前缀或对象标签，方便后续统计。
• 双路径检测终态：
  • 正常执行路径：Lambda A运行过程中自行统计已生成的文件数量，若在5分钟内执行结束（无论是否生成满5个文件），先更新DynamoDB中对应任务的actual_file_count和status=finished字段，再判断b_triggered是否为false，是则调用Lambda B传入全量统计信息，同时将b_triggered更新为true。
  • 超时兜底路径：配置EventBridge每分钟执行一次定时扫描任务，查找DynamoDB中status=running且启动时间已超过5分钟的任务，对命中的任务统计对应S3路径下的实际文件总数，更新任务记录的统计值和status=timeout字段，同样判断b_triggered为false时调用Lambda B，调用后更新b_triggered为true。
• 幂等兜底：Lambda B侧可增加基于task_id的去重逻辑，避免极端情况下的重复触发。

如果不想自行维护DynamoDB状态和扫描逻辑，可直接用Step Functions编排：将Lambda A作为工作流第一个步骤，配置步骤超时为5分钟，无论A执行成功、失败、超时，都流转到S3文件统计步骤，统计完成后再调用Lambda B。Step Functions天生保障工作流终态步骤仅执行一次，无需额外写大量幂等判断代码。

扩展场景（5个独立Lambda生成文件）实现 #

该场景同样可以实现单次触发B的需求，只需调整状态追踪逻辑即可：

• 初始化任务时，在DynamoDB任务记录中为5个Lambda分别预留文件生成状态位，每个Lambda生成完自己负责的文件后，只更新自己对应的状态位、累加actual_file_count。
• 终态判断条件调整为两个，满足任意一个即触发B：
  • actual_file_count达到5，即所有文件全部生成完成
  • 任务启动时间超过5分钟，停止等待直接统计现有文件数
• 终态触发的幂等逻辑、EventBridge超时扫描逻辑和单函数场景完全一致。
• 用Step Functions实现更简单：直接在工作流中添加并行步骤，同时触发5个生成文件的Lambda，配置并行步骤整体超时为5分钟，所有分支执行完成/超时后统一进入聚合统计步骤，最后调用Lambda B即可，全程无需自行维护状态表。

内容的提问来源于stack exchange，提问作者Huy Nguyễn