将 Aurora MySQL 数据更改流式传输到 Kinesis Streams

Question

我正在尝试将Aurora MySQL 数据更改流式传输到 Kinesis 流。考虑到每条记录都应该流式传输到 kinesis 中，最好的方法是什么？

Answer 1

可能有多种方法可以做到这一点，其中一种流行的方法如下：

1. 在集群中启用二进制日志 [1]
2. 有一个读取您的 binlog 流的客户端（可能是 lambda 函数或 ec2 实例）
3. 创建您的 Kinesis 流
4. 让步骤 2 中的客户端发布到 #3 中的 Kinesis 流。

您可以阅读文章[2]和[3]作为参考。您需要的内容分为两个文档。（[3] 适用于 postgres，但有一些关于使用 lambda 或 ec2 客户端的解释）。

[1] https://aws.amazon.com/premiumsupport/knowledge-center/enable-binary-logging-aurora/

[2] https://aws.amazon.com/blogs/database/streaming-changes-in-a-database-with-amazon-kinesis/

[3] https://aws.amazon.com/blogs/database/stream-changes-from-amazon-rds-for-postgresql-using-amazon-kinesis-data-streams-and-aws-lambda/