将 Aurora MySQL 数据更改为 Kinesis Streams

Stream Aurora MySQL data changes into Kinesis Streams

我正在尝试将 Aurora MySQL 数据更改流式传输到 Kinesis 流。考虑到 每条记录都应流式传输到 kinesis

,最好的方法是什么?

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

  1. 在您的集群中启用二进制日志 [1]
  2. 有一个客户端(可能是 lambda 函数或 ec2 实例)读取您的二进制日志流
  3. 创建您的 Kinesis 流
  4. 使第 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/

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