本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
例如:创建简单提醒
在此 Amazon Kinesis 数据分析应用程序中,查询将对基于演示流创建的应用程序内部流持续运行。有关更多信息,请参阅 连续查询。
如果任何行显示股票价格变动大于 1%,这些行将被插入另一个应用程序内部流中。在本练习中,可以将应用程序输出配置为将结果保存到外部目标。随后,可以进一步调查结果。例如,您可以使用 Amazon Lambda 函数处理记录和发送警报。
创建简单的警报应用程序
-
创建分析应用程序,如 Kinesis Data Analytics 中所述。开始使用练习。
-
在 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
。有关说明使用数据泵将行插入应用程序内部流中的编码模式的更多信息,请参阅应用程序代码。 -
选择 Save and run SQL。
-
添加一个目标。为此,请在 SQL 编辑器中选择 Destination (目标),也可以在应用程序中心中选择 Add a destination (添加目标)。
-
在 SQL 编辑器中,选择 Destination (目标) 选项卡,然后选择 Connect to a destination (连接到目标)。
在 Connect to destination (连接到目标) 页面中,选择 Create New (新建)。
-
选择 Go to Kinesis Streams。
-
在 Amazon Kinesis Data Streams 控制台上,创建一个新的 Kinesis 流(例如,
gs-destination
) 有一个碎片。请等待,直到流状态为 ACTIVE。 -
返回 Kinesis Data Analytics 控制台。在 Connect to destination (连接到目标) 页面上,选择您创建的流。
如果流未显示,请刷新页面。
-
选择 Save and continue。
现在,您已拥有一个外部目标 (一个 Kinesis Data Analytics) 会将应用程序输出保存到该目标。
DESTINATION_SQL_STREAM
应用程序内部流。 -
-
配置Amazon Lambda以监控您创建的 Kinesis 流并调用 Lambda 函数。
有关说明,请参阅使用 Lambda 函数预处理数据。