发布于: Mar 25, 2021

Amazon Kinesis Data Analytics for Apache Flink 现在支持使用 Python 版本 3.7 构建的流应用程序。这使您能够以 Python 语言编写流应用程序,并在 Amazon Kinesis Data Analytics 上通过 Apache Flink v1.11 运行。Apache Flink v1.11 通过 Table API 提供对 Python 的支持,这是一个统一的关系 API,用于进行数据处理。

Amazon Kinesis Data Analytics 是使用 Apache Flink 实时转换和分析流数据最简单的方法。Apache Flink 是一种处理数据流的开源框架和引擎。Amazon Kinesis Data Analytics 降低了构建、管理 Apache Flink 应用程序的复杂性。适用于 Apache Flink 的 Amazon Kinesis Data Analytics 集成了 Amazon Managed Streaming for Apache Kafka (Amazon MSK)、Amazon Kinesis Data Streams、Amazon Elasticsearch Service、Amazon DynamoDB Streams、Amazon S3、自定义集成以及更多正在使用的内置连接器。  

您可以在此处了解有关 Amazon Kinesis Data Analytics for Apache Flink 的更多信息,并单击此处开始学习 Python 示例。您可以通过访问官方网站来了解更多有关 Flink 1.11 提供的功能的信息。

请参阅 AWS 区域表,了解 Amazon Kinesis Data Analytics 的区域可用性。