使用 SQL 编辑器 - 适用于 Amazon Kinesis Data Analytics·for·SQL 应用程序开发人员指南

经过仔细考虑,我们决定分两个步骤停用 Amazon Kinesis Data Analytics for SQL 应用程序:

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

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

使用 SQL 编辑器

在下文中,您可以找到有关 SQL 编辑器的各个部分及其工作方式的信息。在 SQL 编辑器中,您可以自行编写代码,也可以选择 Add SQL from templates。SQL 模板为您提供了示例 SQL 代码,可以帮助您编写常见的 Amazon Kinesis Data Analytics 应用程序。本指南中的示例应用程序使用了其中的一些模板。有关更多信息,请参阅 Kinesis Data Analytics for SQL 示例

显示 Real-time analytics (实时分析) 选项卡和应用程序内部流的 SQL 编辑器的屏幕截图。

“Source Data”选项卡

Source data 选项卡可标识流式传输源。它还可标识作为此源的映射目标并提供了应用程序输入配置的应用程序内部输入流。

显示 Source data (源数据) 选项卡的 SQL 编辑器的屏幕截图,并突出显示了流式传输源。

Amazon Kinesis Data Analytics 提供了以下时间戳列,使您无需在输入配置中提供显式映射:

  • ROWTIME - 应用程序内部流中的每一行都具有一个名为 ROWTIME 的特殊列。此列是 Kinesis Data Analytics 在第一个应用程序内部流中插入行的时间戳。

  • Approximate_Arrival_Time - 流式源中的记录包含 Approximate_Arrival_Timestamp 列。它是流式源成功接收和存储相关记录时设置的大致到达时间戳。Kinesis Data Analytics 将该列提取到应用程序内部输入流作为 Approximate_Arrival_Time。Amazon Kinesis Data Analytics 只在映射到流式源的应用程序内部输入流中提供该列。

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

“Real-Time Analytics”选项卡

Real-time analytics (实时分析) 选项卡显示了应用程序代码创建的所有应用程序内部流。这组流包含 Amazon Kinesis Data Analytics 为所有应用程序提供的错误流 (error_stream)。

显示 Real-time analytics (实时分析) 选项卡的 SQL 编辑器的屏幕截图,并突出显示了应用程序内部流。

“Destination”选项卡

Destination (目标) 选项卡可让您配置应用程序输出,以便将应用程序内部流永久保存到外部目标。您可以配置输出,以便将任何应用程序内部流中的数据保存到外部目标。有关更多信息,请参阅 配置应用程序输出