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

创建应用程序-您只需要提供一个名称。控制台创建应用程序，服务将应用程序状态设置为 READY。

配置输入-首先，添加一个流媒体源，即演示流。您必须先在控制台中创建演示流才能使用它。然后，控制台对演示流中的记录进行随机采样，并推断创建的应用程序内部输入流的架构。控制台将应用程序内部流命名为 SOURCE_SQL_STREAM_001。

控制台使用发现 API 来推断架构。如果需要，可以编辑推断的架构。有关更多信息，请参阅DiscoverInputSchema：Kinesis Data Analytics 使用此架构创建应用程序内流。

当您启动应用程序时，Kinesis Data Analytics 会代表您持续读取演示流，并在SOURCE_SQL_STREAM_001应用程序内输入流中插入行。

指定应用程序代码 - 您可以使用提供以下代码的模板（称为连续式筛选器）：

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 参考资料。

配置输出-在本练习中，您不配置任何输出。也就是说，您不会将应用程序创建的应用程序内部流中的数据永久保存到任何外部目标，而应在控制台中验证查询结果。本指南中的其他示例演示了如何配置输出。要查看其中一个示例，请参阅示例：创建简单警报。