步骤 3.3:添加实时分析(添加应用程序代码) - SQL适用于应用程序的 Amazon Kinesis Data Analytics 开发者指南
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

经过仔细考虑,我们决定分两个步骤停止使用亚马逊 Kinesis Data Analytics SQL 的应用程序:

1. 从 2025 年 10 月 15 日起,您将无法为应用程序创建新的 Kinesis Data Analytic SQL s。

2. 我们将从 2026 年 1 月 27 日起删除您的申请。您将无法启动或操作适用于应用程序的 Amazon Kinesis Data Analytic SQL s。从那时起,亚马逊 Kinesis Data Analytics SQL 将不再提供支持。有关更多信息,请参阅 适用于应用程序的 Amazon Kinesis Data Analytic SQL s 停产

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

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

您可以针对应用程序内流编写自己的SQL查询,但是在接下来的步骤中,您可以使用提供示例代码的模板之一。

  1. 在应用程序中心页面上,选择转到SQL编辑器

    带有 “转到SQL编辑器” 按钮的示例应用程序页面的屏幕截图。
  2. 在 “你想开始跑步吗” ExampleApp “? 对话框中,选择 “是,启动应用程序”。

    控制台发送启动应用程序的请求(请参阅StartApplication),然后出现SQL编辑器页面。

  3. 控制台打开SQL编辑器页面。查看页面,包括按钮(SQL从模板添加保存并运行 SQL)和各种选项卡。

  4. 在SQL编辑器中,选择SQL从模板添加

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

    • 它将创建应用程序内部流 DESTINATION_SQL_STREAM

    • 它将创建泵 STREAM_PUMP,并使用此泵从 SOURCE_SQL_STREAM_001 中选择行,并将这些行插入到 DESTINATION_SQL_STREAM

  6. 选择 “将其SQL添加到编辑器”

  7. 按如下方式测试应用程序代码:

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

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

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

      SQL编辑器的屏幕截图,结果显示在 “实时分析” 选项卡中。

      SQL编辑器有以下选项卡:

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

         

        • ROWTIME— 应用程序内流中的每一行都有一个名ROWTIME为的特殊列。此列是 Amazon Kinesis Data Analytics 在首个应用程序内流 (映射到流式源的应用程序内输入流) 中插入行的时间戳。

           

        • Approximate_Arrival_Time - 每个 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)。

         

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

下一个步骤

步骤 3.4:(可选) 更新应用程序代码