将 Python 与托管服务一起使用 Apache Flink - 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。

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

将 Python 与托管服务一起使用 Apache Flink

注意

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

Apache Flink 版本 1.20 支持使用 Python 版本 3.11 创建应用程序。有关更多信息，请参阅 Flink Python 文档。要使用 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 文档中的表 API 教程。