Managed Service for Apache Flink Python アプリケーションの作成 - Managed Service for Apache Flink
コードファイルの指定

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Managed Service for 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 ドキュメント」の「コマンドラインインターフェイス」を参照してください。

注記

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"
          }
        },