第 3 步:创建 StartAmazon Kinesis Data Analytics - Amazon Kinesis Data Analytics 开发人员指南
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

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

第 3 步:创建 StartAmazon Kinesis Data Analytics

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

注意

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

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

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

    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)设置应用程序。您可以使用任何受支持的Amazon Web Services 区域。

下一个步骤

步骤 3.1:创建应用程序