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

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

使用适用于 Apache Flink 的亚马逊托管服务来开发消费端

您可以使用适用于 Apache Flink 的亚马逊托管服务 Flink 应用程序,通过 Java 或 Scala 处理和分析 Kinesis SQL 流中的数据。适用于 Apache Flink 应用程序的托管服务可以使用参考源来丰富数据,聚合一段时间内的数据,或者使用机器学习来查找数据异常。然后,您可以将分析结果写入到另一个 Kinesis 流、Firehose 传输流或 Lambda 函数。有关更多信息,请参阅《适用于 Apache 的托管服务 Flink SQL 应用程序开发人员指南》或《适用于 A pache Flink 的托管服务 Flink 开发人员指南》