使用适用于 Apache Flink 的亚马逊托管服务培养消费者

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