步驟 2：建立 Amazon Kinesis Data Analytics 應用程式

建立應用程式

1. 按照入門練習中的步驟 1、2 和 3 建立 Kinesis Data Analytics 應用程式 (請參閱 步驟 3.1：建立應用程式)。

   在來源設定中，執行下列動作：

   • 指定您在 步驟 1：建立輸入和輸出串流 中建立的串流來源。

   • 主控台推斷結構描述後，請編輯結構描述。請確定 x 和 y 欄類型已設定為 DOUBLE，且 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 程式碼並檢閱結果。