Managed Service for Apache Flink で Python を使用する - Managed Service for Apache Flink

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

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

Managed Service for Apache Flink で Python を使用する

注記

Apple シリコンチップを搭載した新しい Mac で Python Flink アプリケーションを開発している場合、PyFlink 1.15 の Python 依存関係に関する 「既知の問題」 が発生する可能性があります。この場合、Docker で Python インタープリターを実行することをお勧めします。ステップバイステップの手順については、「Apple Silicon Mac での PyFlink 1.15 開発」を参照してください。

Apache Flink バージョン 1.20 には、Python バージョン 3.11 を使用してアプリケーションを作成するためのサポートが含まれています。詳細については、Flink Python のドキュメントを参照してください。Python を使用して Apache Flink アプリケーション用マネージドサービスを作成するには、次の手順を実行します。

  • Python main アプリケーションコードをメソッドを含むテキストファイルとして作成します。

  • アプリケーションコードファイルおよび Python または Java の依存関係を zip ファイルにバンドルし、Amazon S3 バケットにアップロードします。

  • Amazon S3 コードの場所、アプリケーションプロパティ、およびアプリケーション設定を指定して、Apache Flink アプリケーション用 Managed Service を作成します。

大まかに言うと、Python テーブル API は Java テーブル API のラッパーのようなものです。Python Table API の詳細については、Apache Flink ドキュメントの「Table API Tutorial」を参照してください。