使用与 Managed Service for Apache Flink 集成的 Python - Managed Service for Apache Flink
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

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

使用与 Managed Service for Apache Flink 集成的 Python

注意

如果您在搭载 Apple Silicon 芯片的新 Mac 上开发 Python Flink 应用程序，可能会遇到一些与 PyfLink 1.15 的 Python 依赖项有关的已知问题。在这种情况下，我们建议在 Docker 中运行 Python 解释器。有关分步说明，请参阅 Apple Silicon Mac 上的 PyFlink 1.15 开发。

Apache Flink 版本 1.15.2 支持使用 PyfLink 库使用 Python 3.8 版本创建应用程序。要使用 Python 创建 Managed Service for Apache Flink 应用程序，请执行以下操作：

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

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

  • 创建 Managed Service for Apache Flink 应用程序，指定您的 Amazon S3 代码位置、应用程序属性和应用程序设置。

简而言之，Python 表 API 是 Java 表 API 的封装器。有关 Python 表 API 的信息，请参阅 Apache Flink 文档中的 Python 表 API 简介。