本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
将 Python 结合使用 Kinesis Data Analytics
Apache Flink 版本 1.13.2 包括对使用 Python 3.8 版本创建应用程序的支持,使用PyFlink
将 Python 应用程序代码创建为文本文件,并使用
main
方法。将应用程序代码文件和任何 Python 或 Java 依赖项捆绑到 zip 文件中,然后将其上传到 Amazon S3 存储桶。
创建 Kinesis Data Analytics 应用程序,指定 Amazon S3 代码位置、应用程序属性和应用程序设置。
在较高层次上,Python 表 API 是围绕 Java 表 API 的封装器。有关 Python 表 API 的信息,请参阅Python 表 API 简介