示例：创建简单警报 - Amazon Kinesis Data Analytics 开发者指南
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

对于新项目，我们建议您使用新的 Kinesis Data Analytics 工作室，而不是 SQL 应用程序的 Kinesis Data Analytics。Kinesis Data Analytics Studio 将易用性与高级分析功能相结合，使您能够在几分钟内构建复杂的流处理应用程序。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

示例：创建简单警报

在这个 Amazon Kinesis 数据分析应用程序中，查询在通过演示流创建的应用程序内流上持续运行。有关更多信息，请参阅连续查询：

如果任何行显示股票价格变动大于 1%，这些行将被插入另一个应用程序内部流中。在本练习中，可以将应用程序输出配置为将结果保存到外部目标。随后，可以进一步调查结果。例如，您可以使用 Amazon 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 编辑器中选择 Destination (目标)，也可以在应用程序中心中选择 Add a destination (添加目标)。

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

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

    2. 选择 Go to Kinesis Streams。

    3. 在 Amazon Kinesis Data Streams 控制台上，用一个分片创建一个新的 Kinesis 直播（例如gs-destination）。请等待，直到流状态为 ACTIVE。

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

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

    5. 选择 Save and continue。

    现在，您有了外部目标，即 Kinesis 数据流，Kinesis Data Analytics 将应用程序输出保存在DESTINATION_SQL_STREAM应用程序内部流中。

  5. 配置Amazon Lambda为监控您创建的 Kinesis 直播并调用 Lambda 函数。

    有关说明，请参阅 使用 Lambda 函数预处理数据。