创建 Managed Service for Apache Flink Python 应用程序 - 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。

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

创建 Managed Service for Apache Flink Python 应用程序

指定您的代码文件

创建应用程序的代码包后，您可以将其上传到 Amazon S3 存储桶。然后，您可以使用控制台或 “创建应用程序” 操作创建应用程序。

使用 创建应用程序 操作创建应用程序时，您可以使用名为的特殊应用程序属性组在 zip 文件中指定代码文件和存档。kinesis.analytics.flink.run.options您可以定义以下类型文件：

  • python：一个包含 Python 主方法的文本文件。

  • jarfile：一个包含 Java 用户定义函数的 Java JAR 文件。

  • pyFiles：一个 Python 资源文件，其中包含应用程序要使用的资源。

  • pyArchives：一个包含应用程序资源文件的 zip 文件。

有关 Apache Flink Python 代码文件类型的更多信息，请参阅 Apac he Flink 文档中的命令行用法。

注意

Managed Service for Apache Flink 不支持pyModulepyExecutable、或pyRequirements文件类型。所有代码、要求和依赖项都必须位于您的 zip 文件中。您无法使用 pip 指定要安装的依赖项。

以下 json 代码段示例，演示了如何在应用程序的 zip 文件中指定文件位置：

"ApplicationConfiguration": {
    "EnvironmentProperties": {
      "PropertyGroups": [
        {
          "PropertyGroupId": "kinesis.analytics.flink.run.options",
          "PropertyMap": {
            "python": "MyApplication/main.py",
            "jarfile": "MyApplication/lib/myJarFile.jar",
            "pyFiles": "MyApplication/lib/myDependentFile.py",
            "pyArchives": "MyApplication/lib/myArchive.zip"
          }
        },