Приемник DynamoDB для AWS Data Analytics (Flink)
Как можно использовать DynamoDB в качестве приемника для приложения AWS Data Analytics (Flink)?
Я не нашел примеров или существующего класса реализации DynamoDB Sink.
Ответы 3
Официального коннектора DynamoDB для Flink нет.
Тем не менее, существуют различные сторонние, такие как
https://github.com/klarna-incubator/flink-connector-dynamodb
Или
https://github.com/fabricalab/streaming-flink-dynamodb-connector
Я настоятельно рекомендую вам протестировать любые разъемы сторонних производителей, чтобы убедиться, что они готовы к производству и соответствуют вашим потребностям.
Сообщество Apache Flink работает над этим. Это сопутствующий пиар.
Общая ссылка предназначена для соединителя mongodb, а не для dynamodb
Коннектор Dynamo DB Sink теперь доступен, а подробности также доступны в официальной документации.
Пример приложения с использованием пользовательского ElementConverter можно найти здесь . Образец приложения с использованием DynamoDbBeanElementConverter можно найти здесь.
На Github я нашел две независимые реализации: github.com/fabricalab/streaming-flink-dynamodb-connector github.com/klarna-incubator/flink-connector-dynamodb Есть ли официальное решение?