我正在尝试将auroramysql数据更改流到kinesis流。考虑到每一个记录都应该流入动觉的事实，最好的方法是什么呢。
9ceoxa921#
可能有很多方法可以做到这一点，其中一种流行的方法如下：在群集中启用binlog[1]有一个客户端（可能是lambda函数或ec2示例）来读取binlog流创建运动流使第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/
1条答案
按热度按时间9ceoxa921#
可能有很多方法可以做到这一点，其中一种流行的方法如下：
在群集中启用binlog[1]
有一个客户端（可能是lambda函数或ec2示例）来读取binlog流
创建运动流
使第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/