步骤3.3: 添加实时分析（添加应用程序代码）

在应用程序中心页面上，选择 Go to SQL editor。

在 Would you like to start running "ExampleApp"? (是否要开始运行“ExampleApp”？) 对话框中，选择 Yes, start application (是，启动应用程序)。

控制台会发送启动应用程序（请参阅StartApplication）的请求，然后会显示 SQL 编辑器页面。

控制台将打开 SQL 编辑器页面。查看该页面，其中包含多个按钮（Add SQL from templates、Save and run SQL）和不同选项卡。

在 SQL 编辑器中，选择 Add SQL from templates。

从可用模板列表中，选择 Continuous filter。示例代码读取来自一个应用程序内部流的数据 (WHERE 子句将筛选行)，并将数据插入到另一个应用程序内部流，如下所示：

选择 Add this SQL to editor。

按如下方式测试应用程序代码：

请记住，您已启动应用程序（状态为 RUNNING）。因此，Amazon Kinesis Data Analytics 已在持续从流式传输源中读取数据，并将行添加到应用程序内部流 SOURCE_SQL_STREAM_001 中。

1. 在 SQL 编辑器中，选择 Save and run SQL。控制台首先会发送保存应用程序代码的更新请求。然后，代码会持续执行。

2. 您可以在 Real-time analytics 选项卡中查看结果。

   

   SQL 编辑器包含以下选项卡：

   • Source data 选项卡显示映射到流式传输源的应用程序内部输入流。选择应用程序内部流，您可以看到数据不断传入。请注意应用程序内部输入流中未在输入配置中指定的其他列。其中包括以下时间戳列：

      

     • RowTime（RowTime） – 应用内流中的每行都有一个名为 ROWTIME。此列是时间戳 Amazon Kinesis Data Analytics 已插入第一个应用内流（映射到流源的应用内输入流）中的行。

        

     • 近似_抵达_时间 – 每个 Kinesis Data Analytics 记录包括一个名为 Approximate_Arrival_Time。此值是当流源成功接收并存储记录时设置的近似到港时间戳。从流式传输源中读取记录时，Kinesis Data Analytics 将该列提取到应用程序内部输入流中。

     这些时间戳值在基于时间的窗口式查询中非常有用。有关更多信息，请参阅 窗口式查询。)

      

   • Real-time analytics 选项卡显示应用程序代码创建的所有其他应用程序内部流。它还包括错误流。Kinesis Data Analytics 将它无法处理的任何行发送到错误流。有关更多信息，请参阅 错误处理。)

      

     选择 DESTINATION_SQL_STREAM 可查看应用程序代码插入的行。请注意您的应用程序代码未创建的其他列。这些列包括 ROWTIME 时间戳列。Kinesis Data Analytics 直接从源 (SOURCE_SQL_STREAM_001) 中复制这些值。

      

   • Destination (目标) 选项卡显示 Kinesis Data Analytics 将查询结果写入到的外部目标。您尚未为应用程序输出配置任何外部目标。