如何让DynamoDB Streams按Req ID分组触发而非每条记录触发？

结论：无法直接实现 #

DynamoDB Streams的触发逻辑是基于单条记录的变更事件——每条插入、更新或删除操作都会生成一条独立的流记录。因为你的表用MKEY作为主键，三条记录都是独立的条目，哪怕是同一时间插入，也会产生三条流事件，无法自动按Req ID合并成两次触发。

原因说明 #

DynamoDB Streams的核心设计就是捕获单记录级别的变更，这也是全局表能保持多节点精确同步的基础——每个节点的每条记录变更都会被单独捕获并同步。所以不管操作的时间是否一致，只要是不同主键的记录，就会生成独立的流事件。

实现需求的替代方案 #

如果要达到按Req ID分组触发的效果，只能在流的消费环节做处理：

• 消费端聚合：用Lambda消费流记录时，借助临时存储（比如Redis、内存缓存，或者利用Lambda的批量触发特性）按Req ID分组，等同一Req ID的所有记录都被捕获后，再执行后续业务逻辑。需要注意处理超时、重复事件等问题，确保聚合的准确性。
• 调整数据模型：如果业务允许，把同一Req ID的多条记录合并为一条，比如将Req ID设为主键，把ISIN、MKEY等字段存为列表类型。但这种设计会牺牲单条ISIN记录的查询灵活性，需要结合业务场景评估是否适用。

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