Данные потока Aurora MySQL преобразуются в потоки Kinesis - PullRequest
0 голосов
/ 30 октября 2018

Я пытаюсь передать изменения данных Aurora MySQL в потоки Kinesis . Что может быть наилучшим способом сделать это, учитывая тот факт, что каждая запись должна быть передана в кинезис .

1 Ответ

0 голосов
/ 31 октября 2018

Возможно, существует множество способов сделать это, один из самых популярных:

  1. Включить binlogs в вашем кластере [1]
  2. Наличие клиента (возможно, лямбда-функции или экземпляра ec2), который читает ваш поток binlog
  3. Создайте свой поток Kinesis
  4. Сделайте так, чтобы клиент из шага 2 опубликовал ваш поток Kinesis из # 3.

Вы можете прочитать статьи [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/

...