亚马逊 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 存储桶中应用程序的输出。
开始之前,请设置所需的先决条件: