为 Apache Flink Python 应用程序创建你的托管服务 - Managed Service for Apache Flink
指定您的代码文件

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

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

为 Apache Flink Python 应用程序创建你的托管服务

指定您的代码文件

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

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

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

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

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

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

有关 Apache Flink Python 代码文件类型的更多信息，请参阅 Apache 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"
          }
        },