Amazon Kinesis Data Analytics - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

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

Amazon Kinesis Data Analytics

Amazon Kinesis Data Analytics,您可以使用 Java、Scala 或 SQL 来处理和分析流数据。该服务使您能够针对流源编写和运行代码,以执行时间序列分析、提供实时仪表板和创建实时指标。

你可以使用基于 A pache Flink 的开源库在 Kinesis Data Analytics 中构建 Java 和 Scala 应用程序。Apache Flink 是处理数据流的常用框架和引擎。

注意

尽管 Kinesis Data Analytics 支持使用 Scala 版本 2.12 编写的 Apache Flink 应用程序,但本指南仅包含用 Java 编写的代码示例。

Kinesis Data Analytics 为您的 Apache Flink 应用程序提供底层基础架构。它实施一些核心功能,例如,预置计算资源、并行计算、自动扩展和应用程序备份(实施为检查点和快照)。你可以使用高级的 Flink 编程功能(例如运算符、函数、源代码和接收器),就像你自己托管 Flink 基础设施时使用它们一样。

入门

首先,您可以创建一个持续读取和处理流数据的 Kinesis Data Analytics 应用程序。然后,使用您选择的 IDE 编写代码,并使用实时流数据对其进行测试。您还可以配置您希望 Kinesis Data Analytics 发送结果的目的地。

首先,我们建议您阅读以下章节: