

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

# チュートリアル: Amazon Managed Service for Apache Flink を使用してリアルタイムの株式データを分析する
<a name="tutorial-stock-data"></a>

このチュートリアルのシナリオには、株式取引のデータストリームへの取り込みと、ストリームで計算を実行するシンプルな [Amazon Managed Service for Apache Flink](https://docs.aws.amazon.com/kinesisanalytics/latest/java/what-is.html) アプリケーションの記述が含まれます。レコードのストリームを Kinesis Data Streams に送信し、ほぼリアルタイムでレコードを消費および処理するアプリケーションを実装する方法を説明します。

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

Flink アプリケーションは、[Apache Flink](https://flink.apache.org/) に基づくオープンソースライブラリを使用して、Managed Service for Apache Flink で構築できます。Apache Flink は、データストリームを処理するための一般的なフレームワークおよびエンジンです。

**重要**  
2 つのデータストリームとアプリケーションを作成すると、 AWS 無料利用枠の対象とならないため、アカウントでは Kinesis Data Streams と Managed Service for Apache Flink の使用に対してわずかな料金が発生します。このアプリケーションが終了したら、 AWS リソースを削除して料金の発生を停止します。

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

この例では米国西部 (オレゴン) リージョンが使用されていますが、[Managed Service for Apache Flink がサポートされるAWS リージョン](https://docs.aws.amazon.com/general/latest/gr/rande.html#ka_region)であれば、どのリージョンでも動作します。

**Topics**
+ [演習を完了するための前提条件](#setting-up-prerequisites)
+ [AWS アカウントをセットアップし、管理者ユーザーを作成する](setting-up.md)
+ [AWS Command Line Interface (AWS CLI) のセットアップ](setup-awscli.md)
+ [Apache Flink アプリケーション用 Managed Serviceを作成して実行する](get-started-exercise.md)

## 演習を完了するための前提条件
<a name="setting-up-prerequisites"></a>

このガイドの手順を完了するには、以下が必要です。
+ [Java 開発キット](http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html) (JDK) バージョン 8。`JAVA_HOME` 環境変数を、JDK のインストール場所を指すように設定します。
+ 開発環境 ([Eclipse Java Neon](http://www.eclipse.org/downloads/packages/release/neon/3) や [IntelliJ Idea など](https://www.jetbrains.com/idea/)) を使用してアプリケーションを開発し、コンパイルすることをお勧めします。
+ [Git クライアント](https://git-scm.com/book/en/v2/Getting-Started-Installing-Git)。Git クライアントをまだインストールしていない場合は、インストールします。
+ [Apache Maven Compiler Plugin](https://maven.apache.org/plugins/maven-compiler-plugin/)。Maven が作業パスに含まれている必要があります。Apache Maven のインストールをテストするには、次のように入力します。

  ```
  $ mvn -version
  ```

開始するには、[AWS アカウントをセットアップし、管理者ユーザーを作成する](setting-up.md)に進みます。