创建 Python Kinesis Data Analytics 应用程序 - Amazon Kinesis Data Analytics
指定代码文件
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

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

创建 Python Kinesis Data Analytics 应用程序

指定代码文件

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

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

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

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

  • pyFiles：包含应用程序要使用的资源的 Python 资源文件。

  • PyR档案馆：包含应用程序的资源文件的 zip 文件。

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

注意

Kinesis Data Analytics 不支持pyModule、pyExecutable，或者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"
          }
        },