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