经过审慎考虑,我们决定自 2026 年 1 月 27 日起终止对 Amazon Kinesis Data Analytics for SQL 应用程序的支持。我们建议您使用适用于 Apache Flink 的亚马逊托管服务。适用于 Apache Flink 的亚马逊托管服务集简单易用和高级分析功能于一体,它使您能够在几分钟内构建流处理应用程序。您可以我们的文档部分查找代码和架构示例,以帮助您将 Kinesis Data Analytics for SQL 工作负载迁移到适用于 Apache Flink Studio 的亚马逊托管服务。
支持标准 SQL
Kinesis Data Analytics 支持标准 ANSI SQL。
集成输入和输出
Kinesis Data Analytics 与 Amazon Kinesis Data Streams 集成,因此您可以轻松摄取流式传输数据。在输入流指向 Kinesis Data Analytics,即可自动读取、解析数据,并将数据用于处理。您可以通过 Kinesis Data Firehose 将处理结果发送到其他 Amazon Web Services 服务,包括 Amazon S3、Amazon Redshift 和 Amazon OpenSearch Service。您还可以将输出数据发送到 Amazon Kinesis Data Streams,以构建高级流处理管道。
基于控制台的 SQL 编辑器
通过基于控制台的编辑器,使用流数据操作(如滑动时间窗口均值)来构建 SQL 查询。您还可以使用实时数据查看流结果和错误,交互调试或进一步优化您的脚本。
简单易用的架构编辑器
Kinesis Data Analytics 提供了简单易用的架构编辑器来探索和编辑输入数据结构。向导自动识别标准数据格式,例如,JSON 和 CSV。它可以推断输入数据的结构,以创建基准架构,以便于您使用架构编辑器进一步优化。
预先构建的 SQL 模板
交互 SQL 编辑器自带一系列 SQL 模板,其中提供了适用于大部分常见操作类型的基准 SQL 代码,例如,集合、按事件转换和过滤。您可以轻松选择适合您的分析任务的模板,然后编辑使用 SQL 编辑器提供的代码,为您的具体使用案例进行自定义。
高级流处理功能
Kinesis Data Analytics 提供针对流处理优化的功能,因此您可以轻松执行高级分析,例如,对流数据进行异常检测和 top-K 分析。