例: 簡単なアラートの作成 - Amazon Kinesis Data Analytics for SQL Applications デベロッパーガイド

慎重に検討した結果、アプリケーションの Amazon Kinesis Data Analytics は 2 つのステップSQLで中止することにしました。

1. 2025 年 10 月 15 日以降、SQLアプリケーションの新しい Kinesis Data Analytics を作成することはできません。

2. 2026 年 1 月 27 日以降、アプリケーションを削除します。SQL アプリケーションの Amazon Kinesis Data Analytics を開始または操作することはできません。SQL それ以降、Amazon Kinesis Data Analytics のサポートは終了します。詳細については、「Amazon Kinesis Data Analytics for SQL Applications の中止」を参照してください。

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

例: 簡単なアラートの作成

この Kinesis Data Analytics アプリケーションでは、デモストリームを基に作成されたアプリケーション内ストリームに対して、クエリが継続的に実行されます。詳細については、「連続クエリ」を参照してください。

株価の変動が 1% を超えることを示す行があれば、それらの行はアプリケーション内ストリームに挿入されます。実習では、結果を永続化して外部宛先に書き込むようにアプリケーション出力を設定できます。その後、結果を調査できます。たとえば、AWS Lambda 関数を使用してレコードを処理しアラートを送信できます。

シンプルなアラートアプリケーションを作成するには

  1. Kinesis Data Analytics の開始方法の実習に従って分析アプリケーションを作成します。

  2. Kinesis Data Analytics の SQL エディタで、アプリケーションコードを以下に置き換えます。

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
           (ticker_symbol VARCHAR(4), 
            sector        VARCHAR(12), 
            change        DOUBLE, 
            price         DOUBLE);

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  (ABS(Change / (Price - Change)) * 100) > 1;

    アプリケーションコード内の SELECT ステートメントは、SOURCE_SQL_STREAM_001 で、株価の変動が 1% を超える行をフィルタリングします。次に、ポンプを使用して、それらの行を別のアプリケーション内ストリーム (DESTINATION_SQL_STREAM) に挿入します。ポンプを使用したアプリケーション内ストリームへの行の挿入を記述するコーディングパターンの詳細については、「アプリケーションコード」を参照してください。

  3. [Save and run SQL] を選択します。

  4. 宛先を追加します。これを行うには、SQL エディタで [送信先] タブを選択するか、アプリケーション詳細ページで [送信先の追加] を選択します。

    1. SQL エディタで、[送信先] タブを選択し、[送信先への接続] を選択します。

      [送信先への接続] ページで、[新規作成] を選択します。

    2. [Go to Kinesis Streams] を選択します。

    3. Amazon Kinesis Data Streams コンソールで、1 つのシャードを持つ新規の Kinesis ストリーム (gs-destination など) を作成します。ストリームのステータスが [ACTIVE] になるまで待ちます。

    4. Kinesis Data Analytics コンソールに戻ります。[送信先への接続] ページで、作成したストリームを選択します。

      ストリームが表示されない場合は、ページを更新してください。

    5. [Save and continue] を選択します。

    外部宛先として Kinesis データストリームができ、Kinesis Data Analytics はそこに DESTINATION_SQL_STREAM アプリケーション内ストリームのアプリケーション出力を永続化できます。

  5. 作成した Kinesis ストリームをモニタリングして Lambda 関数を呼び出すように AWS Lambda を設定します。

    手順については、「Lambda 関数を使用したデータの事前処理」を参照してください。