使用SQL编辑器 - SQL适用于应用程序的 Amazon Kinesis Data Analytics 开发者指南
“Source Data”选项卡“Real-Time Analytics”选项卡“Destination”选项卡

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

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

使用SQL编辑器

接下来，您可以找到有关SQL编辑器各部分及其工作原理的信息。在SQL编辑器中，您可以自己编写代码，也可以选择SQL从模板中添加。SQL模板为您提供了示例SQL代码，可以帮助您编写常见的 Amazon Kinesis Data Analytics 应用程序。本指南中的示例应用程序使用了其中的一些模板。有关更多信息，请参阅 适用于 SQL 的 Kinesis Data Analytics 示例。

显示实时分析选项卡和应用程序内流的SQL编辑器屏幕截图。

“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)。

SQL编辑器的屏幕截图显示 “实时分析” 选项卡，其中突出显示了应用程序内流。

“Destination”选项卡

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