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

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

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

注意

如果您在搭载 Apple Silicon 芯片的新 Mac 上开发 Python Flink 应用程序，可能会遇到一些与 PyfLink 1.15 的 Python 依赖项有关的已知问题。在这种情况下，我们建议在 Docker 中运行 Python 解释器。有关分步说明，请参阅 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 Table API 是 Java 表 API 的封装器。有关 Python Table API 的信息，请参阅 Apache Flink 文档中的 Table API 教程。