在 Kinesis 控制台中查询您的数据流 - Amazon Kinesis Data Streams

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

在 Kinesis 控制台中查询您的数据流

通过 Kinesis Data Streams 控制台的“数据分析”选项卡,可以使用 SQL 查询数据流。要使用此功能,请按照下列步骤操作:

  1. 登录 AWS Management Console 并在 /kinesis 上打开 Kinesis 控制台。https://console.aws.amazon.com

  2. 选择要使用 SQL 查询的活动数据流,然后选择数据分析选项卡。

  3. 数据分析选项卡中,可以使用托管式 Apache Flink Studio 笔记本执行流检查和可视化。您可以使用 Apache Zeppelin 执行临时 SQL 查询,以检查数据流并在几秒钟内查看结果。在数据分析选项卡中,选择我同意,然后选择创建笔记本,以创建笔记本。

  4. 创建笔记本后,选择在 Apache Zeppelin 中打开。这将在新选项卡中打开您的笔记本。笔记本是一个交互式界面,您可以在其中提交 SQL 查询。选择包含您的流的名称的笔记。

  5. 您将看到一个笔记,其中包含一个示例 SELECT 查询,用于输出已在运行的流中的数据。您可以由此查看数据流的架构。

  6. 要尝试其他查询,例如翻滚或滑动窗口,请在数据分析选项卡中选择查看示例查询。复制查询,对其进行修改以适应您的数据流架构,然后在 Zeppelin 笔记中的新段落中运行它。