使用 SQL 编辑器 - 适用于 Amazon Kinesis Data Analytics·for·SQL 应用程序开发人员指南
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

对于新项目,建议您使用新的适用于 Apache Flink Studio 的托管服务,而不是使用 Kinesis Data Analytics for SQL 应用程序。Managed Service for Apache Flink Studio 不仅操作简单,还具有高级分析功能,使您能够在几分钟内构建复杂的流处理应用程序。

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

使用 SQL 编辑器

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

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