用 Fargate 将 PostgreSQL 变更送入 S3 RSS

AWS 给出一条由托管组件组成的 PostgreSQL 变更采集链路：Fargate 任务通过 wal2json 读取逻辑复制流，将事件交给 EventBridge，再经 SQS 与 Lambda 写入 S3。方案省去自建消息集群，适合将行级变化留作分析输入，同时把采集、缓冲与落盘拆开扩缩。运维重点仍包括复制槽滞后和 WAL 保留上限、队列死信与重试，以及下游幂等处理；队列采用至少一次投递，不能把组件托管等同于端到端恰好一次。

发布于 2026-09-26T23:37:08.078947Z · Ramdas Gutlapalli、Rishika Kasani、Lokesh Chauhan · AWS Database Blog

AWS CDC 对象存储

AWS 给出一条由托管组件组成的 PostgreSQL 变更采集链路：Fargate 任务通过 wal2json 读取逻辑复制流，将事件交给 EventBridge，再经 SQS 与 Lambda 写入 S3。方案省去自建消息集群，适合将行级变化留作分析输入，同时把采集、缓冲与落盘拆开扩缩。运维重点仍包括复制槽滞后和 WAL 保留上限、队列死信与重试，以及下游幂等处理；队列采用至少一次投递，不能把组件托管等同于端到端恰好一次。

AWS 给出一条由托管组件组成的 PostgreSQL 变更采集链路：Fargate 任务通过 wal2json 读取逻辑复制流，将事件交给 EventBridge，再经 SQS 与 Lambda 写入 S3。方案省去自建消息集群，适合将行级变化留作分析输入，同时把采集、缓冲与落盘拆开扩缩。运维重点仍包括复制槽滞后和 WAL 保留上限、队列死信与重试，以及下游幂等处理；队列采用至少一次投递，不能把组件托管等同于端到端恰好一次。

原始来源 ↗

来源记录

• pgweb.info_item · 4bdee34c77040194 · 2026-10-03T04:08:55.967155Z