如何基于DynamoDB实现发布/订阅模式？

1. DynamoDB Streams 能否作为发布/订阅解决方案？ #

DynamoDB Streams 可作为基础组件，但直接用于全节点订阅存在局限——它采用分片独占消费模型：每个流分片仅能被一个消费者（或消费者组内的单个实例）占用，已消费的记录不会重复推送给其他消费者。你的理解完全正确：默认情况下，同一条流记录只会被消费一次，无法直接让所有云节点接收同一条事件。

不过可以通过多独立消费者组的方式规避该限制：为每个云节点（或节点集群）创建独立的 Streams 消费者组，每组独立消费全量流数据。但这种方式会提升资源消耗，需评估成本与性能是否适配你的场景。

2. DynamoDB 是否支持类似 tail cursor 的功能？ #

DynamoDB Streams 原生提供**分片迭代器（Shard Iterator）**机制，通过指定不同迭代器类型可实现类似 tail 的效果：

• TRIM_HORIZON：从流的最早可用记录开始消费
• LATEST：仅消费调用迭代器后新增的记录，即实时“tail”流的最新数据
• AT_SEQUENCE_NUMBER/AFTER_SEQUENCE_NUMBER：从指定序列号的位置开始消费

获取分片迭代器后，可循环调用 GetRecords 拉取数据；当前迭代器耗尽时，使用返回的 NextShardIterator 继续拉取，以此实现持续监听流的效果，逻辑与 tail -f 类似。

3. 其他可利用的特性与补充方案 #

若单纯依赖 Streams 无法满足全节点订阅需求，可结合以下方案：

• 全局表 + Streams：若节点分布在多区域，全局表可自动同步数据变更，各区域的 Streams 可被当地节点消费，实现跨区域事件通知。
• Streams + Lambda + SNS/SQS：在 Streams 下游配置 Lambda 函数，将流数据转发至 SNS 主题；每个云节点订阅该主题（或通过 SQS 队列做缓冲）。SNS 原生支持一对多发布/订阅，完美匹配全节点接收事件的场景，这也是业内常用架构。
• TTL 事件表：创建专门的事件表，发送事件时写入带 TTL 的记录（自动过期清理）；每个节点定期扫描表内新增记录（可配合最后扫描时间戳做条件查询）。该方式实现简单，适合低频率事件通知，但实时性不如 Streams。

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