AWS EventBridge能否实现双S3 PutObject事件触发Lambda？求配置方案

首先明确：纯EventBridge事件规则无法直接实现“等待两个S3 PutObject事件都触发后再执行Lambda”的逻辑，但可以通过EventBridge结合其他AWS组件实现这个需求，以下是两种实用方案：

这个方案适合需要自定义状态管理的场景：

• 1. 配置两个S3桶的事件通知：将s3:PutObject事件发送到同一个EventBridge事件总线（默认总线或自定义总线），确保事件中包含桶名、文件名等关键信息。
• 2. 创建DynamoDB状态表：表结构建议用correlationId（关联标识，比如对应文件的共同文件名/业务ID）作为主键，再添加bucketA_uploaded、bucketB_uploaded两个布尔类型字段，用于记录上传状态。
• 3. 创建EventBridge规则：匹配两个S3的PutObject事件，触发一个状态更新Lambda。
  • 该Lambda的逻辑：从事件中解析桶名和关联ID，更新DynamoDB中对应记录的上传状态；更新完成后检查两个状态是否都为true，如果是，则调用目标业务Lambda执行处理逻辑；如果不是，则结束。
• 4. 业务Lambda执行完成后，可选择删除DynamoDB中的对应状态记录，避免重复触发。

利用EventBridge Pipes的事件聚合功能，直接凑齐两个事件后触发Lambda：

• 1. 同样先配置两个S3桶将PutObject事件发送到EventBridge总线。
• 2. 创建EventBridge Pipe：
  • 源选择EventBridge事件总线，添加事件过滤规则，仅匹配两个目标S3桶的s3:PutObject事件。
  • 设置聚合规则：选择计数聚合类型，设置聚合计数为2；指定correlationId（比如从事件的文件名中提取）作为分组键，确保同一业务关联的事件被分到同一组。
  • 设置聚合窗口超时（比如30分钟），避免未凑齐的事件一直占用资源。
  • 目标选择你的业务Lambda，当同一分组凑齐2个事件时，Pipe会将聚合后的事件批量发送给Lambda执行。

• 关联标识（correlationId）必须唯一对应一组需要配对的文件，比如两个桶的对应文件使用相同文件名，或文件名包含统一业务ID，否则无法正确配对。
• 务必为业务Lambda实现幂等性，避免因重复事件导致重复执行。
• 聚合窗口超时时间需根据业务场景设置，平衡等待时间和资源占用。

内容的提问来源于stack exchange，提问作者s.agarwala