步骤 3 创建您的起点 Amazon Kinesis Data Analytics 应用 - Amazon Kinesis Data Analytics for SQL 应用程序开发人员指南
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

如果我们为英文版本指南提供翻译,那么如果存在任何冲突,将以英文版本指南为准。在提供翻译时使用机器翻译。

步骤 3 创建您的起点 Amazon Kinesis Data Analytics 应用

通过按照本节中的步骤操作,您可以使用控制台创建您的第一个 Kinesis Data Analytics 应用程序。

注意

在尝试入门练习之前,我们建议您先查看 适用于 SQL 应用程序的 Amazon Kinesis Data Analytics :工作方式

在本入门练习中,您可以通过控制台来使用演示流或包含应用程序代码的模板。

  • 如果您选择使用演示流,控制台将在您的账户中创建一个名为 kinesis-analytics-demo-stream 的 Kinesis 数据流。

    Kinesis 数据分析应用程序需要使用流式传输源。对于此源,本指南中的SQL示例使用演示流 kinesis-analytics-demo-stream。控制台还运行一个脚本,该脚本将会持续向此流添加样品数据(模拟库存交易记录),如下所示。

    
                        显示股票代号、部门和价格的 Formatted stream sample (格式化的流示例) 表。

    在本练习中,您可以使用 kinesis-analytics-demo-stream 作为应用程序的流式传输源。

    注意

    演示流会保留在账户中。您可以使用它测试本指南中的其他示例。但是,如果您退出控制台,控制台使用的脚本会停止填充数据。控制台可在需要时提供重新开始填充流的选项。

  • 如果您选择使用包含示例应用程序代码的模板,请使用控制台提供的模板代码对演示流执行简单分析。

您可以使用如下这些功能快速设置您的首个应用程序:

  1. 创建应用程序 – 您只需提供一个名称。控制台创建应用程序,服务将应用程序状态设置为 READY

     

  2. 配置输入 – 首先,您添加流式传输源,即演示流。您必须先在控制台中创建演示流才能使用它。然后,控制台对演示流中的记录进行随机采样,并推断创建的应用程序内部输入流的架构。控制台将应用程序内部流命名为 SOURCE_SQL_STREAM_001

    控制台使用发现 API 来推断架构。如果需要,可以编辑推断的架构。有关更多信息,请参阅 DiscoverInputSchema。Kinesis Data Analytics 使用此架构创建应用程序内部流。

     

    在启动应用程序时,Kinesis Data Analytics 代表您持续读取演示流,并在 SOURCE_SQL_STREAM_001 应用程序内部输入流中插入行。

     

  3. 指定应用程序代码 – 您使用提供以下代码的模板(称为连续筛选器):

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE); -- Create pump to insert into output. 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 sector SIMILAR TO '%TECH%';

    应用程序代码查询应用内流 SOURCE_SQL_STREAM_001。代码随后在另一个应用中的流中插入所生成的行 DESTINATION_SQL_STREAM,使用泵。有关此编码模式的更多信息,请参阅应用程序代码

    有关 Kinesis Data Analytics 支持的 SQL 语言元素的信息,请参阅 Amazon Kinesis Data Analytics SQL 参考

     

  4. 配置输出 – 在此练习中,您不会配置任何输出。也就是说,您不会将应用程序创建的应用程序内部流中的数据永久保存到任何外部目标,而应在控制台中验证查询结果。本指南中的其他示例演示了如何配置输出。要查看其中一个示例,请参阅示例:创建简单警报

重要

本练习使用 美国东部(弗吉尼亚北部) 区域 (us-east-1) 设置应用程序。您可以使用支持的任意 AWS 区域。

下一步

步骤3.1: 创建应用程序