使用适用于 Apache Flink 的亚马逊托管服务 - Amazon Data Firehose
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

亚马逊 Data Firehose 以前被称为亚马逊 Kinesis Data Firehose

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

使用适用于 Apache Flink 的亚马逊托管服务

借助 Amazon Managed Service for Apache Flink,您可以使用 Java、Scala 或 SQL 来处理和分析流数据。该服务使您能够针对流源编写和运行代码,以执行时间序列分析,馈送实时控制面板和创建实时指标。

有关与适用于 Apache Flink 的亚马逊托管服务集成的示例,请参阅示例:写入亚马逊数据 Fire hose。

在本练习中,您将创建一个 Apache Flink 应用程序,该应用程序以 Kinesis 数据流作为源,将 Firehose 流作为接收器。您可以使用接收器验证 Amazon S3 存储桶中应用程序的输出。

开始之前,请设置所需的先决条件: