将 Python 结合使用 Kinesis Data Analytics - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

将 Python 结合使用 Kinesis Data Analytics

Apache Flink 版本 1.13.2 包括对使用 Python 3.8 版本创建应用程序的支持，使用PyFlink库. 您可以通过执行以下操作使用 Python 创建 Kinesis Data Analytics 应用程序：

  • 将 Python 应用程序代码创建为文本文件，并使用main方法。

  • 将应用程序代码文件和任何 Python 或 Java 依赖项捆绑到 zip 文件中，然后将其上传到 Amazon S3 存储桶。

  • 创建 Kinesis Data Analytics 应用程序，指定 Amazon S3 代码位置、应用程序属性和应用程序设置。

在较高层次上，Python 表 API 是围绕 Java 表 API 的封装器。有关 Python 表 API 的信息，请参阅Python 表 API 简介中的Apache Flink 文档.