经过仔细考虑，我们决定停用适用于 SQL 应用程序的 Amazon Kinesis Data Analytics：

1. 从 **2025年9月1日起，**我们将不再为适用于SQL应用程序的Amazon Kinesis Data Analytics Data Analytics提供任何错误修复，因为鉴于即将停产，我们对其的支持将有限。

2. 从 **2025 年 10 月 15 日**起，您将无法为 SQL 应用程序创建新的 Kinesis Data Analytics。

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. 选择 **保存并运行 SQL**。

1. 添加一个目标。为此，请在 SQL 编辑器中选择 **Destination (目标)**，也可以在应用程序中心中选择 **Add a destination (添加目标)**。

   1. 在 SQL 编辑器中，选择 **Destination (目标)** 选项卡，然后选择 **Connect to a destination (连接到目标)**。

      在 **Connect to destination (连接到目标)** 页面中，选择 **Create New (新建)**。

   1. 选择 **Go to Kinesis Streams**。

   1. 在 Amazon Kinesis Data Streams 控制台中，创建具有一个分片的新 Kinesis 流（例如，`gs-destination`）。请等待，直到流状态为 **ACTIVE**。

   1. 返回 Kinesis Data Analytics 控制台。在 **Connect to destination (连接到目标)** 页面上，选择您创建的流。

      如果流未显示，请刷新页面。

   1. 选择 **保存并继续**。

   现在，您具有一个外部目标（Kinesis 数据流），Kinesis Data Analytics 将 `DESTINATION_SQL_STREAM` 应用程序内部流中的应用程序输出永久保存到该目标中。

1. 配置 AWS Lambda 为监控您创建的 Kinesis 流并调用 Lambda 函数。

   有关说明，请参阅[使用 Lambda 函数预处理数据](lambda-preprocessing.md)。