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