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

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

什么是 Apache Flink 的 Amazon Kinesis Data Analytics?

借助适用于 Apache Flink 的 Amazon Kinesis Data Analytics,您可以使用 Java、Scala 或 SQL 来处理和分析流数据。您可以使用该服务针对流式传输源创建和运行代码,以执行时间序列分析,为实时控制面板提供信息以及创建实时指标。

您可以在 Kinesis Data Analytics 中使用基于Apache Flink。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 要将结果发送到的目标。

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