チュートリアル: Flink アプリケーション用の Kinesis Data Analytics を使用した株式データのリアルタイム分析 - Amazon Kinesis Data Streams

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

チュートリアル: Flink アプリケーション用の Kinesis Data Analytics を使用した株式データのリアルタイム分析

このチュートリアルのシナリオでは、株式取引をストリームに取り込み、シンプルなAmazon Kinesis Data Analyticsストリームで計算を実行するアプリケーション。レコードのストリームを Kinesis Data Streams に送信し、ほぼリアルタイムにレコードを消費および処理するアプリケーションを実装する方法を説明します。

Flink アプリケーション用の Amazon Kinesis Data Analytics では、Java または Scala を使用してストリーミングデータを処理および分析できます。このサービスでは、ストリーミングソースに対する Java コードまたは Scala コードを作成して実行し、時系列分析の実行、ダッシュボードへのリアルタイムフィード、メトリクスのリアルタイム作成を行うことができます。

Kinesis Data Analytics で Flink アプリケーションは、ベースのオープンソースライブラリを使用して構築できます。Apache Flink。Apache Flink は、データストリームを処理するための一般的なフレームワークおよびエンジンです。

重要

2 つのデータストリームとアプリケーションを作成した後、Kinesis Data Streams と Kinesis Data Analytics の使用に関するわずかな料金が発生します。これらはAWS無料利用枠。このアプリケーションを終了したら、あなたのAWS料金の発生を停止するリソース。

このコードでは、実際の株式市場データにアクセスする代わりに、株式取引のストリームをシミュレートします。そのために、ランダム株式取引ジェネレーターが使用されます。リアルタイムの株式取引のストリームにアクセスできたとしたら、そのときに必要としている有益な統計を入手したいと考えるかもしれません。たとえば、スライディングウィンドウ分析を実行して、過去 5 分間に購入された最も人気のある株式を調べたいと思われるかもしれません。または、大規模な売り注文 (膨大な株式が含まれる売り注文) が発生したときに通知を受けたいと思われるかもしれません。このシリーズのコードを拡張して、このような機能を使用することもできます。

この例では、米国西部 (オレゴン) リージョンが使用されていますが、これらのAWSKinesis Data Analytics をサポートするリージョン

演習を完了するための前提条件

このガイドの手順を完了するには、以下が必要です。

  • Java 開発キット (JDK) バージョン 8。JAVA_HOME 環境変数を、JDK のインストール場所を指すように設定します。

  • 開発環境 (Eclipse Java NeonIntelliJ Idea など) を使用してアプリケーションを開発し、コンパイルすることをお勧めします。

  • Git クライアント。 Git クライアントをまだインストールしていない場合は、インストールします。

  • Apache Maven Compiler Plugin。Maven が作業パスに含まれている必要があります。Apache Maven のインストールをテストするには、次のように入力します。

    $ mvn -version
    注記

    Flink アプリケーション用の Kinesis Data Analytics は、Apache Maven で構築された Java と Flink アプリケーションのみをサポートします。

開始するには、「ステップ 1: のセットアップAWSアカウントと管理者ユーザーの作成」に進みます。