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

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

步骤 2. 创建 Kinesis Data Analytics 应用程序

热点示例的此部分中,您创建一个 Amazon Kinesis 数据分析应用程序,如下所示:

  • 配置应用程序输入以将在步骤 1 中创建的 Kinesis 数据流作为流式传输源。

  • 在 AWS 管理控制台中使用提供的应用程序代码。

创建应用程序

  1. 按照入门练习中的步骤 1、2 和 3 创建 Kinesis 数据分析应用程序(请参阅步骤3.1: 创建应用程序)。

    在源配置中,执行以下操作:

    • 指定您在步骤 1. 创建输入和输出流中创建的流式传输源。

    • 在控制台推断架构后编辑架构。确保 xyDOUBLE 列类型设置为 ,并确保 IS_HOT 列类型设置为 VARCHAR.

  2. 使用以下应用程序代码 (您可以将此代码粘贴到 SQL 编辑器中):

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( "x" DOUBLE, "y" DOUBLE, "is_hot" VARCHAR(4), HOTSPOTS_RESULT VARCHAR(10000) ); CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT "x", "y", "is_hot", "HOTSPOTS_RESULT" FROM TABLE ( HOTSPOTS( CURSOR(SELECT STREAM "x", "y", "is_hot" FROM "SOURCE_SQL_STREAM_001"), 1000, 0.2, 17) );
  3. 运行 SQL 代码并审查结果。

    
                            显示行时间、热点和 hotspot_heat 的 SQL 代码结果。

下一步

步骤 3 配置应用程序输出