為阿帕奇 Flink Python 應用程序創建您的託管服務 - Managed Service for Apache Flink
指定您的程式碼檔案

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

為阿帕奇 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 不支援 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"
          }
        },