ステップ 3: スターター Amazon Kinesis Data Analytics アプリケーションを作成する

アプリケーションの作成 – 名前を指定するだけです。コンソールによってアプリケーションが作成され、サービスによってアプリケーションの状態が READY に設定されます。

入力の設定 – まず、ストリーミングソースとしてデモストリームを追加します。これを使用するには、コンソールでデモストリームを作成する必要があります。その後、コンソールは、デモストリームのレコードをランダムにサンプリングして、作成されるアプリケーション内入力ストリームのスキーマを推測します。コンソールは、アプリケーション内ストリームを SOURCE_SQL_STREAM_001 と命名します。

コンソールは検出APIを使用してスキーマを推測します。必要に応じて、推測スキーマを編集できます。詳細については、「DiscoverInputSchema」を参照してください。Kinesis Data Analytics では、このスキーマを使用してアプリケーション内ストリームを作成します。

アプリケーションを開始すると、Kinesis Data Analytics はユーザーに代わってデモストリームを継続的に読み取り、アプリケーション内入力ストリームの SOURCE_SQL_STREAM_001 に行を挿入します。

アプリケーションコードの指定 – 次のコードを提供するテンプレート ([Continuous filter] といいます) を使用します。

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
  (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE);
 
-- Create pump to insert into output. 
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
   INSERT INTO "DESTINATION_SQL_STREAM"  
      SELECT STREAM ticker_symbol, sector, CHANGE, price
      FROM "SOURCE_SQL_STREAM_001"
      WHERE sector SIMILAR TO '%TECH%';

このアプリケーションコードでは、アプリケーション内ストリーム (SOURCE_SQL_STREAM_001) をクエリします。また、ポンプを使用して、表示された行を別のアプリケーション内ストリーム (DESTINATION_SQL_STREAM) に挿入します。コーディングパターンの詳細については、「アプリケーションコード」を参照してください。

Kinesis Data Analytics でサポートされているSQL言語要素の詳細については、Amazon Kinesis Data Analytics SQLリファレンス」を参照してください。

出力の設定 – この実習では、出力は設定しません。つまり、アプリケーションが作成するアプリケーション内ストリームのデータを外部宛先で永続化しません。代わりに、コンソールでクエリの結果を確認します。このガイドのその他の例では、出力を設定する方法について説明します。例については、「例: 簡単なアラートの作成」を参照してください。