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

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

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

在 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/秒 数据,独立于任何其他管道或使用者的总数量。