Amazon Kinesis Data Streams
开发人员指南
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

利用使用增强型扇出功能的使用者

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

重要

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

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


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

此图显示以下内容:

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

  • 使用增强型扇出功能接收流中数据的两个使用者:使用者 X 和使用者 Y。这两个使用者均已订阅流的所有分片和所有记录。如果使用 2.0 版或更高版本的 KCL 构建使用者,则 KCL 将自动为使用者订阅流的所有分片。另一方面,如果使用 API 构建使用者,则可订阅单个分片。

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