开发具有专用吞吐量的自定义使用者(增强扇出功能) - Amazon Kinesis Data Streams
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

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

开发具有专用吞吐量的自定义使用者(增强扇出功能)

在 Amazon Kinesis Data Streams 中,可以构建使用所谓的增强型扇出功能 的使用者。利用此功能,使用者可以从流中接收记录,其数据吞吐量高达每分片 2 MB/秒。此吞吐量是专用的,这意味着,使用增强型扇出功能的使用者不必与接收流中数据的其他使用者争夺。Kinesis Data Streams 将流中的数据记录推送到使用增强型扇出功能的使用者。因此,这些使用者无需轮询数据。

重要

您可以为每个流注册多达 20 个使用者,以便使用增强型扇出功能。

下图显示的是增强型扇出功能架构。如果使用 2.0 版或更高版本的 Amazon Kinesis Client Library (KCL) 构建使用者,则 KCL 会将使用者设置为使用增强型扇出功能接收来自流的所有分片的数据。如果使用 API 构建使用增强型扇出功能的使用者,则可订阅单个分片。


            显示具有两个分片和两个使用者的增强型扇出功能架构的工作流程图。这两个使用者均使用增强型扇出功能接收来自流的两个分片的数据。

此图显示以下内容:

  • 一个具有两个分片的流。

  • 使用增强扇出来接收来自流的数据的两个消费者: 消费者X和消费者Y。这两个消费者都订阅了所有的数据库和流股。如果使用 2.0 版或更高版本的 KCL 构建使用者,则 KCL 将自动为使用者订阅流的所有分片。另一方面,如果使用 API 构建使用者,则可订阅单个分片。

  • 表示使用者用于接收流中数据的增强型扇出功能管道的箭头。增强型扇出功能管道每分片提供高达 2 MB/秒 数据,独立于任何其他管道或使用者的总数量。