Managed Service for Apache Flink の Python の例

次の例は、Python で記述されたアプリケーションを作成する方法を示しています。

注記

ほとんどの例は、ローカル、開発マシン、IDE任意の、Amazon Managed Service for Apache Flink の両方で実行されるように設計されています。これらは、アプリケーションパラメータを渡すために使用できるシンプルなメカニズムと、両方の環境でアプリケーションを変更せずに実行するように依存関係を正しく設定する方法を示しています。

プロジェクトの依存関係

ほとんどの PyFlink 例では、Flink コネクタなど、JARファイルとして 1 つ以上の依存関係が必要です。これらの依存関係は、Amazon Managed Service for Apache Flink にデプロイするときに、アプリケーションと共にパッケージ化する必要があります。

次の例には、開発とテストのためにアプリケーションをローカルで実行し、必要な依存関係を正しくパッケージ化できるツールが既に含まれています。このツールでは、Java JDK11と Apache Maven を使用する必要があります。具体的な手順については、各例READMEに含まれる「」を参照してください。

例

この例では、Python コードにSQL埋め込まれたを使用する PyFlink アプリケーションの基本構造を示しています。このプロジェクトでは、コネクタなどのJAR依存関係を含む PyFlink アプリケーションのスケルトンも提供します。README このセクションでは、開発のために Python アプリケーションをローカルで実行する方法に関する詳細なガイダンスを提供します。この例では、この例の Kinesis SQL コネクタという単一のJAR依存関係をアプリケーションに含める方法も示しています PyFlink。

コード例: GettingStarted

この例では、Python の依存関係を最も一般的な方法で PyFlink アプリケーションに追加する方法を示します。このメソッドは、Boto3 などの単純な依存関係や、などの C ライブラリを含む複雑な依存関係に対して機能します PyArrow。

コード例: PythonDependencies

この例では、Python アプリケーションにSQL埋め込まれたの 4 種類のウィンドウ集約を示しています。