View a markdown version of this page

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

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

将 Python 与 Managed Service for Apache Flink 结合使用

注意

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

Apache Flink 版本 2.2 支持使用 Python 版本 3.12 创建应用程序；已删除对 Python 版本 3.8 的支持。有关更多信息，请参阅 Flink Python 文档。要使用 Python 创建 Managed Service for Apache Flink 应用程序，请执行以下操作：

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

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

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

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