翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
Amazon Managed Service for Apache Flink
Apache Flink を使用して、時系列データを Amazon Managed Service for Apache Flink、Amazon MSK、Apache Kafka、およびその他のストリーミングテクノロジーから Amazon Timestream for に直接転送できます LiveAnalytics。Timestream 用の Apache Flink サンプルデータコネクタを作成しました。また、データを Amazon Kinesis に送信するためのサンプルアプリケーションも作成しました。これにより、データは Kinesis から Managed Service for Apache Flink に流れ、最後に Amazon Timestream に流れます。これらのアーティファクトはすべて、 で入手できます GitHub。このビデオチュートリアル
注記
Java 11 は、 Managed Service for Apache Flink Application を使用するための推奨バージョンです。複数の Java バージョンがある場合は、Java 11 を JAVA_HOME 環境変数にエクスポートしてください。
サンプルアプリケーション
開始するには、以下の手順に従います。
-
Timestream で、「」で説明されている手順に従って、 という名前のデータベースを作成します
kdaflink。 データベースを作成する -
Timestream で、「」で説明
kinesisdata1されている手順に従って という名前のテーブルを作成する テーブルを作成する -
「ストリームの作成」で説明されている
TimestreamTestStream手順に従って、名前で Amazon Kinesis Data Stream を作成する -
の指示に従って、Timestream の Apache Flink データコネクタの
GitHub リポジトリをクローンします。 GitHub -
サンプルアプリケーションをコンパイル、実行、使用するには、Apache Flink サンプルデータコネクタの指示に従います。 README
-
Managed Service for Apache Flink アプリケーションをコンパイルするには、アプリケーションコードのコンパイルの手順に従います。
-
Apache Flink ストリーミングコードをアップロードする手順に従って、Managed Service for Apache Flink アプリケーションバイナリをアップロードします。
-
アプリケーションの作成をクリックし、アプリケーションのIAMロールのリンクをクリックします。
-
AmazonKinesisReadOnlyAccess と のIAMポリシーをアタッチしますAmazonTimestreamFullAccess。
注記
上記のIAMポリシーは特定のリソースに限定されず、本番稼働での使用には適していません。本番稼働システムでは、特定のリソースへのアクセスを制限するポリシーの使用を検討してください。
-
-
の指示に従って、Kinesis にデータを書き込むサンプルアプリケーションの
GitHub リポジトリをクローンします。 GitHub -
の手順に従ってREADME
、Kinesis にデータを書き込むためのサンプルアプリケーションを実行します。 -
Timestream で 1 つ以上のクエリを実行して、 の指示に従って、データが Kinesis から Managed Service for Apache Flink から Timestream に送信されていることを確認します。 テーブルを作成する
チュートリアル動画
このビデオ
