Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
Managed Service for Apache Flink アプリケーションを作成する
このトピックでは、Managed Service for Apache Flink アプリケーションの作成について説明します。
このトピックには、次のセクションが含まれています。
Managed Service for Apache Flink アプリケーションコードを構築する
このセクションでは、Managed Service for Apache Flink アプリケーションのアプリケーションコードの構築に使用するコンポーネントについて説明します。
アプリケーションコードに対してサポートされている最新バージョンの Apache Flink を使用することをお勧めします。Apache Flink アプリケーション用 Managed Service のアップグレードについては、Apache Flink のインプレースバージョンアップグレードを使用する を参照してください。
アプリケーションコードは「Apache Mavenpom.xml」ファイルを使用して、使用するコンポーネントのバージョンを指定します。
注記
Managed Service for Apache Flink は、最大 512 MB のJARファイルをサポートします。これより大きいJARファイルを使用すると、アプリケーションは起動できません。
アプリケーションは、API任意の Scala バージョンの Java を使用できるようになりました。選択した Scala 標準ライブラリを Scala アプリケーションにバンドルする必要があります。
「Apache Beam」を使用する Apache Flink アプリケーション用 Managed Service の作成については、 Managed Service for Apache Flink アプリケーションで Apache Beam を使用する を参照してください。
アプリケーションの Apache Flink バージョンを指定する
Apache Flink Runtime バージョン 1.1.0 以降の Managed Service を使用する場合は、アプリケーションをコンパイルするときにアプリケーションが使用する Apache Flink のバージョンを指定します。-Dflink.version パラメータを使用して Apache Flink のバージョンを指定します。例えば、Apache Flink 1.19.1 を使用している場合は、以下を指定します。
mvn package -Dflink.version=1.19.1
以前のバージョンの Apache Flink を使用してアプリケーションを構築する方法については、「」を参照してください以前のバージョン。
Managed Service for Apache Flink アプリケーションを作成する
アプリケーションコードを作成したら、以下を実行して Managed Service for Apache Flink アプリケーションを作成します。
「アプリケーションコードのアップロード:」アプリケーションコードを Amazon S3 バケットにアップロードします。アプリケーションを作成する際は、アプリケーションコードの S3 バケット名とオブジェクト名を指定します。アプリケーションコードのアップロード方法を示すチュートリアルについては、チュートリアル: Managed Service for Apache Flink で の使用 DataStream APIを開始する「」チュートリアルを参照してください。
「Apache Flink アプリケーション用 Managed Service の作成」:以下のいずれかの方法を使用して Apache Flink アプリケーション用 Managed Service を作成します。
AWS コンソールを使用して Managed Service for Apache Flink アプリケーションを作成する： AWS コンソールを使用してアプリケーションを作成および設定できます。
コンソールを使用してアプリケーションを作成すると、アプリケーションの依存リソース ( CloudWatch ログストリーム、IAMロール、IAMポリシーなど) が自動的に作成されます。
コンソールを使用してアプリケーションを作成する場合、「Apache Flink 用 Managed Service - アプリケーションの作成」ページのプルダウンから選択して、アプリケーションが使用する Apache Flink のバージョンを指定します。
コンソールを使用してアプリケーションを作成する方法のチュートリアルについては、チュートリアル: Managed Service for Apache Flink で の使用 DataStream APIを開始する「」チュートリアルを参照してください。
を使用して Managed Service for Apache Flink アプリケーションを作成します AWS CLI。 を使用してアプリケーションを作成および設定できます AWS CLI。
を使用してアプリケーションを作成する場合はCLI、アプリケーションの依存リソース ( CloudWatch ログストリーム、IAMロール、IAMポリシーなど) も手動で作成する必要があります。
を使用してアプリケーションを作成するときはCLI、
CreateApplicationアクションのRuntimeEnvironmentパラメータを使用して、アプリケーションが使用する Apache Flink のバージョンを指定します。
注記
既存のアプリケーションの
RuntimeEnvironmentを変更できます。この方法の詳細は、Apache Flink のインプレースバージョンアップグレードを使用するを参照してください。
Managed Service for Apache Flink アプリケーションを起動する
アプリケーションコードを作成し、S3 にアップロードし、Apache Flink アプリケーション用 Managed Service を作成したら、アプリケーションを起動します。Apache Flink 用 Managed Service アプリケーションの起動には、通常数分かかります。
アプリケーションを起動するには、以下のいずれかの方法を使用します。
AWS コンソールを使用して Managed Service for Apache Flink アプリケーションを起動する： AWS コンソールのアプリケーションのページで実行を選択して、アプリケーションを実行できます。
を使用して Managed Service for Apache Flink アプリケーションを起動します AWS API。 StartApplicationアクションを使用してアプリケーションを実行できます。
Managed Service for Apache Flink アプリケーションを検証する
アプリケーションが動作していることを確認するには、次の方法があります。
CloudWatch ログの使用： CloudWatch Logs と Logs Insights CloudWatch を使用して、アプリケーションが正しく実行されていることを確認できます。Managed Service for Apache Flink アプリケーションで CloudWatch ログを使用する方法については、「」を参照してくださいAmazon Managed Service for Apache Flink でのログ記録とモニタリング。
CloudWatch メトリクスの使用： CloudWatch メトリクスを使用して、アプリケーションのアクティビティ、またはアプリケーションが入力または出力に使用するリソース (Kinesis ストリーム、Firehose ストリーム、Amazon S3 バケットなど) のアクティビティをモニタリングできます。 CloudWatch メトリクスの詳細については、「Amazon ユーザーガイド」の「メトリクスの使用 CloudWatch 」を参照してください。
「出力ロケーションのモニタリング:」アプリケーションが出力を特定のロケーション (Amazon S3 バケットやデータベースなど) に書き込む場合、そのロケーションに書き込まれたデータを監視できます。
