慎重に検討した結果、Amazon Kinesis Data Analytics for SQL アプリケーションを中止することにしました。

1. **2025 年 9 月 1** 日以降、Amazon Kinesis Data Analytics for SQL アプリケーションのバグ修正は提供されません。これは、今後の廃止によりサポートが制限されるためです。

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

3. **2026 年 1 月 27 日**以降、アプリケーションは削除されます。Amazon Kinesis Data Analytics for SQL アプリケーションを起動することも操作することもできなくなります。これ以降、Amazon Kinesis Data Analytics for SQL のサポートは終了します。詳細については、「[Amazon Kinesis Data Analytics for SQL アプリケーションのサポート終了](discontinuation.md)」を参照してください。

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

# 例: 調整されたアラートの作成
<a name="app-throttled-alerts"></a>

この Kinesis Data Analytics アプリケーションでは、デモストリームを基に作成されたアプリケーション内ストリームに継続的にクエリが実行されます。詳細については、「[連続クエリ](continuous-queries-concepts.md)」を参照してください。株価の変動が 1% を超えることを示す行があれば、それらの行はアプリケーション内ストリームに挿入されます。アプリケーションはアラートを調整し、株価が変動したときにただちにアラートが送信されるようにします。ただし、1 分あたり、株式シンボルあたり複数のアラートがアプリケーション内ストリームに送信されることはありません。

**調整されたアラートアプリケーションを作成するには**

1. Kinesis Data Analytics の[開始方法](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/get-started-exercise.html)の実習に従って Kinesis Data Analytics アプリケーションを作成します。

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

   ```
   CREATE OR REPLACE STREAM "CHANGE_STREAM" 
              (ticker_symbol VARCHAR(4), 
               sector        VARCHAR(12), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "change_pump" AS 
      INSERT INTO "CHANGE_STREAM"
         SELECT STREAM ticker_symbol, sector, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  (ABS(Change / (Price - Change)) * 100) > 1;
         
   -- ** Trigger Count and Limit **
   -- Counts "triggers" or those values that evaluated true against the previous where clause
   -- Then provides its own limit on the number of triggers per hour per ticker symbol to what
   -- is specified in the WHERE clause
   
   CREATE OR REPLACE STREAM TRIGGER_COUNT_STREAM (
      ticker_symbol VARCHAR(4), 
      change REAL,
      trigger_count INTEGER);
   
   CREATE OR REPLACE PUMP trigger_count_pump AS INSERT INTO TRIGGER_COUNT_STREAM
   SELECT STREAM ticker_symbol, change, trigger_count
   FROM (
       SELECT STREAM ticker_symbol, change, COUNT(*) OVER W1 as trigger_count
       FROM "CHANGE_STREAM"
       --window to perform aggregations over last minute to keep track of triggers
       WINDOW W1 AS (PARTITION BY ticker_symbol RANGE INTERVAL '1' MINUTE PRECEDING)
   )
   WHERE trigger_count >= 1;
   ```

   アプリケーション内の `SELECT` ステートメントは、`SOURCE_SQL_STREAM_001` の行を、1 パーセントを超える株価の変動でフィルタリングして、ポンプを使用してそれらの行を別のアプリケーション内ストリーム `CHANGE_STREAM` に挿入します。

   アプリケーションは、調整されたアラートに `TRIGGER_COUNT_STREAM` と呼ばれる 2 番目のストリームを作成します。2 番目のクエリはレコードが入力されるたびにホップするウィンドウからレコードを選択します。これにより、株価ティッカーごとに 1 分あたり 1 つのレコードのみがストリームに書き込まれます。

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

例では、`TRIGGER_COUNT_STREAM` に次のようなストリームが出力されます。

![\[ティッカーシンボル、変動率、およびトリガーカウントの各列を含む出力ストリームを示すコンソールのスクリーンショットです。\]](http://docs.aws.amazon.com/ja_jp/kinesisanalytics/latest/dev/images/ex-throttle-alerts.png)