本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
從 Amazon Kinesis Data Streams 讀取資料
取用者是處理來自 Kinesis 資料串流的所有資料的應用程式。當消費者使用強化廣發功能時,將取得其自身每秒 2 MB 的讀取傳輸量配額,使得多個消費者能夠並行從同一串流讀取資料,而不必與其他消費者爭用讀取傳輸量。若要使用碎片的強化廣發功能,請參閱開發具備專用傳輸量的自訂消費者 (強化廣發功能)。
預設情況下,串流中的碎片提供每個碎片每秒 2 MB 的讀取傳輸量。此傳輸量由讀取指定之碎片的所有消費者共用。換言之,預設的每個碎片每秒 2 MB 傳輸量為固定,即使有多個消費者讀取該碎片亦然。若要使用碎片的此一預設傳輸量,請參閱開發具備共用傳輸量的自訂消費者。
下表比較對強化廣發功能的預設傳輸量。訊息傳播延遲定義為透過有效負載消耗的 API (例如和) 透過有效負載消耗的 API (例如和) 傳送的有效負載傳送有效負載 API (例如 PutRecord 和 PutRecords) 傳送的有效負載所花費的時間 (以毫秒為單位)。 GetRecords SubscribeToShard
特性 | 不具強化廣發功能的未註冊消費者 | 具有強化廣發功能的已註冊消費者 |
---|---|---|
碎片讀取傳輸量 | 固定為每個碎片每秒總共 2 MB。若有多個消費者從同一碎片讀取,所有這些消費者將共用此傳輸量。消費者每秒從碎片接收的傳輸量總和不超過 2 MB。 | 隨著消費者註冊使用強化廣發功能而擴展。已註冊使用強化廣發功能的各消費者均接收其自身的每個碎片讀取傳輸量,最多每秒 2 MB,獨立於其他消費者。 |
訊息傳播延遲 | 若您有一個來自串流的消費者讀數,平均約為 200 ms。若您有五個消費者,則此平均數會上升至約 1000 ms。 | 一般而言,無論您有一個或五個消費者,平均為 70 ms。 |
費用 | N/A | 分為資料擷取成本和消費者碎片小時成本。如需詳細資訊,請參閱 Amazon Kinesis Data Streams 定價 |
記錄交付模式 | 使用 HTTP 提取模型GetRecords。 | Kinesis Data Streams 會使用 HTTP/2 將記錄推送給您。SubscribeToShard |
主題
- 在 Kinesis 主控台中使用資料檢視器
- 在 Kinesis 主控台中查詢您的資料串流
- 開發消費者使用 AWS Lambda
- 開發使用 Amazon Managed Service for Apache Flink 的取用者
- 使用 Amazon 數據 Firehose 開發消費者
- 使用 Kinesis Client Library
- 開發具備共用傳輸量的自訂消費者
- 開發具備專用傳輸量的自訂消費者 (強化廣發功能)
- 將消費者從 KCL 1.x 遷移到 KCL 2.x
- 使用其他 AWS Services 讀取來自 Kinesis Data Streams 的資料
- 使用第三方整合
- 疑難排解 Kinesis 資料串流消費者
- Amazon Kinesis Data Streams 消費者進階主題