Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
Studio ノートブックを作成する
Studio ノートブックにはSQL、ストリーミングデータに対して実行され、分析結果が返される、、Python、または Scala で記述されたクエリまたはプログラムが含まれています。コンソールまたは を使用してアプリケーションを作成しCLI、データソースからのデータを分析するためのクエリを提供します。
アプリケーションには次のコンポーネントがあります。
Amazon MSKクラスター、Kinesis データストリーム、Amazon S3 バケットなどのデータソース。
AWS Glue データベース。このデータベースには、データソースとデスティネーションスキーマとエンドポイントを格納するテーブルが含まれています。詳細については、「の操作 AWS Glue」を参照してください。
アプリケーションコード。顧客のコードは分析クエリまたはプログラムを実装します。
アプリケーション設定とランタイムプロパティ。アプリケーション設定とランタイムプロパティについては、「 Apache Flink Applications 用デベロッパーガイド」の以下のトピックを参照してください。
「アプリケーションの並列度とスケーリング： 」アプリケーションの並列度設定を使用して、アプリケーションが同時に実行できるクエリの数を制御します。また、以下のような場合は、複数の実行経路を持つクエリは、並列度の向上を利用することができます。
Kinesis データストリームの複数のシャードを処理する場合
KeyByオペレータを使用してデータを分割する場合。複数のウィンドウオペレータを使用する場合
アプリケーションスケーリングの詳細情報については、「Apache Flink 用 Managed Service のアプリケーションスケーリング」を参照してください。
ロギングとモニタリング: アプリケーションのロギングとモニタリングについては、「Apache Flink 向けの Amazon Managed Service for Apache Flink でのロギングとモニタリング」を参照してください。
-
アプリケーションでは、チェックポイントとセーブポイントを使用してフォールトトレランスを行います。Studio ノートブックでは、チェックポイントとセーブポイントはデフォルトでは有効になっていません。
Studio ノートブックは、 AWS Management Console または を使用して作成できます AWS CLI。
コンソールからアプリケーションを作成する場合、以下のオプションがあります：。
Amazon MSKコンソールでクラスターを選択し、リアルタイム でデータを処理する を選択します。
Kinesis Data Streams コンソールでデータストリームを選択し、次に [アプリケーション] タブで [データをリアルタイムで処理] を選択します。
Apache Flink 用 Managed Service コンソールで [Studio] タブを選択し、次に [Studio ノートブックの作成] を選択します。
チュートリアルについては、「Managed Service for Apache Flink によるイベント検出
アドバンスト Studio ノートブックソリューションの例については、「Amazon Managed Service for Apache Flink Studio の Apache Flink
