

慎重に検討した結果、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-simple-alerts"></a>

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

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

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

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

1. 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`) に挿入します。ポンプを使用したアプリケーション内ストリームへの行の挿入を記述するコーディングパターンの詳細については、「[アプリケーションコード](how-it-works-app-code.md)」を参照してください。

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

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

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

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

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

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

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

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

   1. **[保存して続行]** を選択します。

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

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

   手順については、「[Lambda 関数を使用したデータの事前処理](lambda-preprocessing.md)」を参照してください。