步骤 2：创建分析应用程序

创建应用程序

1. 打开 Kinesis 控制台，网址为：https://console.aws.amazon.com/kinesis。

2. 在导航窗格中选择 Data Analytics (数据分析)，然后选择创建应用程序。

3. 提供应用程序名称和描述 (可选)，并选择 Create application。

4. 选择 Connect streaming data (连接流数据)，然后从列表中选择 ExampleInputStream。

5. 选择 Discover schema，并确保 Systolic 和 Diastolic 显示为 INTEGER 列。如果二者为另一种类型，则选择 Edit schema，并将 INTEGER 类型分配给二者。

6. 在 Real time analytics 下，选择 Go to SQL editor。出现提示时，选择运行您的应用程序。

7. 将以下代码粘贴到 SQL 编辑器中，然后选择 Save and run SQL。

   --Creates a temporary stream.
   CREATE OR REPLACE STREAM "TEMP_STREAM" (
   	        "Systolic"                  INTEGER,
   	        "Diastolic"                 INTEGER,
   	        "BloodPressureLevel"        varchar(20),
   	        "ANOMALY_SCORE"             DOUBLE,
   	        "ANOMALY_EXPLANATION"       varchar(512));
   
   --Creates another stream for application output.	        
   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
   	        "Systolic"                  INTEGER,
   	        "Diastolic"                 INTEGER,
   	        "BloodPressureLevel"        varchar(20),
   	        "ANOMALY_SCORE"             DOUBLE,
   	        "ANOMALY_EXPLANATION"       varchar(512));
   
   -- Compute an anomaly score with explanation for each record in the input stream
   -- using RANDOM_CUT_FOREST_WITH_EXPLANATION
   CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
      INSERT INTO "TEMP_STREAM"
         SELECT STREAM "Systolic", "Diastolic", "BloodPressureLevel", ANOMALY_SCORE, ANOMALY_EXPLANATION 
         FROM TABLE(RANDOM_CUT_FOREST_WITH_EXPLANATION(
                 CURSOR(SELECT STREAM * FROM "SOURCE_SQL_STREAM_001"), 100, 256, 100000, 1, true));
   
   -- Sort records by descending anomaly score, insert into output stream
   CREATE OR REPLACE PUMP "OUTPUT_PUMP" AS 
      INSERT INTO "DESTINATION_SQL_STREAM"
         SELECT STREAM * FROM "TEMP_STREAM"
         ORDER BY FLOOR("TEMP_STREAM".ROWTIME TO SECOND), ANOMALY_SCORE DESC;