本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
开发具有专用吞吐量的自定义使用者(增强扇出功能)
在 Amazon Kinesis Data Streams 中,您可以构建使用名为的功能的使用者增强的扇出. 利用此功能,使用者可以从流中接收记录,其数据吞吐量高达每分片 2 MB/秒。此吞吐量是专用的,这意味着,使用增强型扇出功能的使用者不必与接收流中数据的其他使用者争夺。Kinesis Data Streams 将流中的数据记录推送到使用增强型扇出功能的使用者。因此,这些使用者无需轮询数据。
重要
您可以为每个流注册多达 20 个使用者,以便使用增强型扇出功能。
下图显示的是增强型扇出功能架构。如果使用 2.0 版或更高版本的 Amazon Kinesis 客户端库 (KCL) 构建使用者,则 KCL 会将使用者设置为使用增强型扇出功能接收来自流的所有分片的数据。如果使用 API 构建使用增强型扇出功能的使用者,则可订阅单个分片。

此图显示以下内容:
-
一个具有两个分片的流。
-
使用增强型扇出功能接收流中数据的两个使用者:使用者 X 和使用者 Y。这两个使用者均已订阅流的所有分片和所有记录。如果使用 2.0 版或更高版本的 KCL 构建使用者,则 KCL 将自动为使用者订阅流的所有分片。另一方面,如果使用 API 构建使用者,则可订阅单个分片。
-
表示使用者用于接收流中数据的增强型扇出功能管道的箭头。增强型扇出功能管道每分片提供高达 2 MB/秒 数据,独立于任何其他管道或使用者的总数量。