0

我的要求是仅将我数据库中特定表上的 INSERT 流式传输到 Kinesis 数据流。

我已经在我的 AWS 环境中配置了这个管道：

RDS Postgres 13 -> DMS (Database Migration Service) -> KDS (Kinesis Data Stream)

此设置工作正常，但它处理我的源表上的所有更改，甚至更新和删除。

我试过的：

  • 在 Postgres 逻辑解码插件中寻找配置选项。DMS 使用test_decodingPG 插件，该插件不接受按操作类型包含/排除数据更改的选项。
  • 查看 DMS 选择和过滤规则。仍然没有看到任何可能有帮助的东西。

当然，我可以在我的 Kinesis 消费者中简单地忽略源自非 INSERT 操作的记录，但这看起来不像是一种具有成本效益的实现方式。

有什么方法可以使用这些 AWS 服务（RDS -> DMS -> Kinesis）来满足我的要求？

4

0 回答 0