适用于 Apache Flink 的亚马逊托管服务现在支持将 Amazon DynamoDB Streams 作为源

发布于: 2024年11月12日

今天,AWS 宣布支持用于 Amazon DynamoDB 的新 Apache Flink 连接器。这款新连接器由 AWS 为 Apache Flink 开源项目提供,它增加了 Amazon DynamoDB Streams 作为 Apache Flink 的新源。您现在可以使用 Apache Flink 来处理 DynamoDB 流事件,Apache Flink 是一种用于处理和分析流数据的常用框架和引擎。

Amazon DynamoDB 是一项无服务器的 NoSQL 数据库服务,您可以通过它来开发任何规模的现代应用程序。DynamoDB Streams 在 DynamoDB 表中提供了一个按时间排序的项目级更改(插入、更新和删除)序列。借助适用于 Apache Flink 的亚马逊托管服务,您可以使用 Apache Flink 实时转换和分析 DynamoDB 流数据,并将应用程序与其他 AWS 服务(例如 Amazon S3、Amazon OpenSearch、Amazon Managed Streaming for Apache Kafka 等)集成。Apache Flink 连接器是软件组件,用于将数据移入和移出适用于 Apache Flink 的亚马逊托管服务应用程序。从 Apache Flink 版本 1.19 开始,您可以使用新的连接器从 DynamoDB 流中读取数据。使用适用于 Apache Flink 的亚马逊托管服务,无需管理服务器和集群,也无需设置计算和存储基础设施。

您可以在此处了解适用于 AWS 连接器的 Apache Flink 存储库。有关详细文档和设置说明,请访问我们的文档页面