連続クエリ - Amazon Kinesis Data Analytics for SQL Applications 開発者ガイド

新規プロジェクトでは、Kinesis Data Analytics for SQL よりも 新しい Managed Service for Apache Flink Studio を使用することをお勧めします。Managed Service for Apache Flink Studio は、使いやすさと高度な分析機能を兼ね備えているため、高度なストリーム処理アプリケーションを数分で構築できます。

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

連続クエリ

ストリーム上のクエリは、ストリーミングデータに対して連続して実行されます。この連続実行によって、アプリケーションが連続してストリーミングにクエリしアラートを生成する機能などのシナリオが可能になります。

「使用開始」の実習では、SOURCE_SQL_STREAM_001 という名前のアプリケーション内ストリームを使用します。これはデモストリーム (Kinesis データストリーム) から連続して株価を受信します。スキーマは次のとおりです。

(TICKER_SYMBOL VARCHAR(4), 
 SECTOR varchar(16), 
 CHANGE REAL, 
 PRICE REAL)

15 パーセントを超える株価の変動に関心があるとします。アプリケーションコードで次のクエリを使用できます。このクエリは連続して実行され、15 パーセントを超える株価の変動が検出された場合にレコードを発行します。

SELECT STREAM TICKER_SYMBOL, PRICE 
      FROM   "SOURCE_SQL_STREAM_001"
      WHERE  (ABS((CHANGE / (PRICE-CHANGE)) * 100)) > 15

次の手順を使用して Amazon Kinesis Data Analytics アプリケーションをセットアップし、このクエリをテストします。

クエリをテストするには

  1. 「使用開始」実習に従ってアプリケーションを作成します。

  2. アプリケーションコード内の SELECT ステートメントを前述の SELECT クエリに置き換えます。アプリケーションコードは次のようになります。

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), 
                                                   price DOUBLE);
-- CREATE OR REPLACE PUMP to insert into output
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
  INSERT INTO "DESTINATION_SQL_STREAM" 
      SELECT STREAM TICKER_SYMBOL, 
                    PRICE 
      FROM   "SOURCE_SQL_STREAM_001"
      WHERE  (ABS((CHANGE / (PRICE-CHANGE)) * 100)) > 15;