開發具備專用傳輸量的自訂消費者 (強化廣發功能) - Amazon Kinesis Data Streams

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

開發具備專用傳輸量的自訂消費者 (強化廣發功能)

在 Amazon Kinesis Data Streams 中,您可以建置使用所謂強化廣發功能的取用者。藉助這項功能,消費者從串流接收記錄可高達每個碎片每秒 2 MB 的資料傳輸量。此輸送量係屬專用,也就是說使用強化廣發功能的取用者不必與其他從串流接收資料的取用者競爭。Kinesis Data Streams 會將資料記錄從串流推送至使用強化廣發功能的取用者。因此,這類消費者無須輪詢資料。

重要

每個串流可註冊多達二十個使用強化廣發功能的消費者。

下圖顯示強化廣發功能的架構。若您使用 2.0 版或更新版本的 Amazon Kinesis Client Library (KCL) 建置取用者,KCL 會將取用者設定成使用強化廣發功能從串流中的所有碎片接收資料。如果您是使用 API 建置使用強化廣發功能的消費者,則可以訂閱個別的碎片。

顯示具有兩個碎片和兩個消費者的強化廣發功能架構工作流程圖。兩個消費者各自使用強化廣發功能從串流中的兩個碎片接收資料。

上圖顯示以下項目:

  • 具有兩個碎片的串流。

  • 使用強化廣發功能從串流接收資料的兩個消費者:消費者 X 和消費者 Y。兩個消費者均已訂閱串流中的所有碎片和所有記錄。若您使用 2.0 版或更新版本的 KCL 建置取用者,KCL 將自動為取用者訂閱串流中的所有碎片。另一方面,如果您是使用 API 建置消費者,則可以訂閱個別的碎片。

  • 箭頭代表消費者用於從串流接收資料的強化廣發功能管道。強化廣發功能管道提供每個碎片每秒高達 2 MB 的資料,獨立於任何其他管道且與消費者總數無關。