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