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

在该热点示例的此部分中，您创建一个 Kinesis Data Analytics 应用程序，如下所示：

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

• 在 AWS Management Console中使用提供的应用程序代码。

创建应用程序

1. 按照入门练习中的步骤 1、2 和 3（请参阅 步骤 3.1：创建应用程序）创建 Kinesis Data Analytics 应用程序。

   在源配置中，执行以下操作：

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

   • 在控制台推断架构后编辑架构。确保 x 和 yDOUBLE 列类型设置为 ，并确保 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 代码并审查结果。

   

下一个步骤

步骤 3：配置应用程序输出