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 依赖项有关的已知问题
Apache Flink 版本 1.15.2 支持使用 PyfLink 库使用 Python 3.8 版本创建应用程序。
使用
main
方法将您的 Python 应用程序代码创建为文本文件。将您的应用程序代码文件和任何 Python 或 Java 依赖项捆绑到一个 zip 文件中,然后将其上传到 Amazon S3 存储桶。
创建 Managed Service for Apache Flink 应用程序,指定您的 Amazon S3 代码位置、应用程序属性和应用程序设置。
简而言之,Python 表 API 是 Java 表 API 的封装器。有关 Python 表 API 的信息,请参阅 Apache Flink 文档