Amazon Kinesis Data Analytics

サーバーレス Apache Flink でストリーミングデータから実用的なインサイトを取得

Amazon Kinesis Data Analytics は、Apache Flink でストリーミングデータをリアルタイムで変換および分析できる最も簡単な方法です。Apache Flink はオープンソースのフレームワークであり、データストリームを処理するためのエンジンです。Amazon Kinesis Data Analytics を利用すると、Apache Flink アプリケーションを構築し、管理し、AWS のサービスと統合する作業がシンプルになります。

Amazon Kinesis Data Analytics では、ストリーミングアプリケーションを継続的に実行するために必要なものすべてが提供され、受信データのボリュームとスループットレートに応じて自動的にスケールされます。Amazon Kinesis Data Analytics を使用すれば、ストリーミングアプリケーションが使用するリソースに対してのみお支払いいただきます。サーバーを管理することも、最低料金やセットアップ費用がかかることもありません。

PoC (概念実証) または評価に関するサポートをリクエスト >>

利点

強力なリアルタイム処理

Amazon Kinesis Data Analytics には、高度な分析のためにストリーミングデータをフィルタリング、集約、変換する機能が組み込まれています。1 秒未満のレイテンシーでストリーミングデータを処理するため、着信データおよびイベントをリアルタイムで分析し、応答することができます。

サーバー管理が不要

Amazon Kinesis Data Analytics はサーバーレスです。管理するサーバーがありません。完全マネージド型なので、インフラストラクチャをプロビジョニングしたり管理したりする必要なく、ストリーミングアプリケーションを実行できます。Amazon Kinesis Data Analytics は、受信データを処理するために必要に応じてインフラストラクチャを自動的に拡大および縮小します。

支払いは実際に使用した分のみ

Amazon Kinesis Data Analytics では、ストリーミングアプリケーションによって使用される処理リソースについてのみお支払いいただきます。最低料金や初期費用は不要です。

使いやすい

Amazon Kinesis Data Analytics では、ストリーミングデータソースの設定、クエリまたはストリーミングアプリケーションの作成、処理済みデータの送信先の設定という 3 つの簡単なステップで、クエリと高度なストリーミングアプリケーションを簡単かつ迅速に構築できます。

Amazon Kinesis Data Analytics には Apache Flink をベースとしたオープンソースライブラリとランタイムが含まれているため、お気に入りの IDE を使用して、数か月ではなく数時間でアプリケーションを構築できます。拡張可能なライブラリには、ステートフルストリーム処理、ストリーミング ETL、リアルタイム分析など、さまざまなユースケースに特化した API が含まれています。ライブラリを使用して、Apache Kafka 用の Amazon Managed Streaming (Amazon MSK)、Amazon Kinesis Data Streams、Amazon Kinesis Data Firehose、Amazon Elasticsearch Service、Amazon S3、Amazon DynamoDB などの AWS サービスと統合できます。

対話型クエリに標準 SQL を使用する

Amazon Kinesis Data Analytics では、結合、一定期間の集計、フィルタなどを実行する SQL クエリを作成できるテンプレート、およびインタラクティブなエディタが用意されています。そのため、分析タスクに適切なテンプレートを選択して、SQL エディタを使用して提供されているコードを編集し、特定のユースケースに合わせてカスタマイズするだけで済みます。コードを 1 行も書くことなく、SQL 結果を AWS Lambda、Amazon Kinesis Data Streams、Amazon Kinesis Data Firehose などの他の AWS のサービスに送信できます。

Apache Beam でストリーミングアプリケーションを構築する

Amazon Kinesis Data Analytics は、サーバーレス Apache Flink 環境で Apache Beam の Java SDK を介して構築されたストリーミングアプリケーションの実行をサポートします。Apache Beam は、複数の実行エンジンで実行できるストリーミングおよびバッチデータ処理アプリケーションを定義するためのオープンソースの統合モデルです。Java で Apache Beam ストリーミングアプリケーションを簡単に構築し、Amazon Kinesis Data Analytics やその他の実行エンジンで実行できます。

仕組み

Amazon Kinesis Data Analytics の仕組み

ユースケース

ストリーミング ETL

Amazon Kinesis Data Analytics 組み込み演算子を使用してストリーミング抽出変換ロード (ETL) アプリケーションを開発し、ストリーミングデータを変換、集約、およびフィルタリングできます。組み込みコネクタを使えば、Amazon Kinesis Data Streams、Apache Kafka 用 Amazon Managed Streaming (Amazon MSK)、Amazon Elasticsearch Service、Amazon S3、カスタム統合などに数秒で簡単にデータを配信できます。

John Deere が農業機器から IoT センサー測定値を抽出し、リアルタイムでデータを有用な顧客情報に変換し、変換されたデータをデータレイクにロードする方法をご覧ください。

リアルタイム分析

標準 SQL でストリーミングデータをインタラクティブにクエリしたり、Java と Scala を使って Apache Flink アプリケーションを構築したり、Java で Apache Beam アプリケーションを構築してデータストリームを分析したりできます。

ログのモニタリングウェブ分析に関するリアルタイム分析ソリューションの概要について、ご覧ください。

ステートフルなイベント処理

1 つ以上のデータストリームからのイベントを処理し、条件付き処理と外部アクションをトリガーするアプリケーションを開発できます。複雑なイベント処理用の標準 SQL および Apache Flink ライブラリを使用して、データストリームの異常検出などのパターンを識別できます。

プレイヤーのアクションによってトリガーされたゲームイベントを Zynga がどのように処理するかを確認してください。

お客様

Autodesk の導入事例
Autodesk は、応答時間とエラー率スパイクなど、ユーザーのエクスペリエンスをモニタリングするためのリアルタイムモニタリングメトリクスを計算します。
導入事例を読む 
ジンガ
Fox は、Super Bowl などのライブ動画ストリーミングイベントのリアルタイムビューワー分析を計算します。
ブログ投稿を読む 
ジンガ
Zynga はプレーヤーの操作によって起動される大量のリアルタイムゲームイベントを分析します。
動画を見る 
Palringo の導入事例
Palringo はリアルタイムメトリクスを用いてモバイルコミュニティゲームアプリへのユーザーの参加を拡大しています。
導入事例を読む 
Gunosy のブログ投稿
Gunosy は 1 分あたり 50 万件を超えるレコードを処理してエンドユーザーのための個人向けニュースの選定を高速化しています。
ブログ投稿を読む 

Amazon Kinesis Data Analytics の使用を開始する

AWS アカウントにサインアップする
AWS アカウントにサインアップする

AWS 無料利用枠にすぐにアクセスできます。

入門ガイドを読む
入門ガイドを見る

SQL または Apache Flink のステップバイステップガイドで Amazon Kinesis Data Analytics の使用方法を学習できます。

Amazon Kinesis Data Analytics で構築を開始する
ストリーミングアプリケーションの構築を開始する

Amazon Kinesis Data Analytics コンソールを使用してストリーミングアプリケーションを構築します。