将 Aurora MySQL 数据更改为 Kinesis Streams
Stream Aurora MySQL data changes into Kinesis Streams
我正在尝试将 Aurora MySQL 数据更改流式传输到 Kinesis 流。考虑到 每条记录都应流式传输到 kinesis。
,最好的方法是什么?
可能有很多方法可以做到这一点,其中一种流行的方法如下:
- 在您的集群中启用二进制日志 [1]
- 有一个客户端(可能是 lambda 函数或 ec2 实例)读取您的二进制日志流
- 创建您的 Kinesis 流
- 使第 2 步中的客户端从#3 发布到您的 Kinesis 流。
您可以阅读文章[2]和[3]以供参考。您需要的是在两个文档之间分配。 ([3] 适用于 postgres,但对使用 lambdas 或 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/
我正在尝试将 Aurora MySQL 数据更改流式传输到 Kinesis 流。考虑到 每条记录都应流式传输到 kinesis。
,最好的方法是什么?可能有很多方法可以做到这一点,其中一种流行的方法如下:
- 在您的集群中启用二进制日志 [1]
- 有一个客户端(可能是 lambda 函数或 ec2 实例)读取您的二进制日志流
- 创建您的 Kinesis 流
- 使第 2 步中的客户端从#3 发布到您的 Kinesis 流。
您可以阅读文章[2]和[3]以供参考。您需要的是在两个文档之间分配。 ([3] 适用于 postgres,但对使用 lambdas 或 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/