選取您的 Cookie 偏好設定

我們使用提供自身網站和服務所需的基本 Cookie 和類似工具。我們使用效能 Cookie 收集匿名統計資料,以便了解客戶如何使用我們的網站並進行改進。基本 Cookie 無法停用,但可以按一下「自訂」或「拒絕」以拒絕效能 Cookie。

如果您同意,AWS 與經核准的第三方也會使用 Cookie 提供實用的網站功能、記住您的偏好設定,並顯示相關內容,包括相關廣告。若要接受或拒絕所有非必要 Cookie,請按一下「接受」或「拒絕」。若要進行更詳細的選擇,請按一下「自訂」。

使用 DynamoDB Streams Kinesis 轉接器處理串流記錄

焦點模式
使用 DynamoDB Streams Kinesis 轉接器處理串流記錄 - Amazon DynamoDB

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

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

建議透過 Amazon Kinesis 轉接器耗用來自 Amazon DynamoDB 的串流。DynamoDB Streams API刻意與 Kinesis Data Streams 類似,Kinesis Data Streams 是一種用於大規模即時處理串流資料的服務。在這兩種服務中,資料串流由碎片組成,碎片是用於串流紀錄的容器。這兩個服務都APIs包含 ListStreamsGetShardsDescribeStreamGetShardIterator操作。(雖然這些 DynamoDB Streams 動作與其在 Kinesis Data Streams 中的對應動作類似,但它們並非完全相同。)

您可以使用 Kinesis 用戶端程式庫 () 撰寫 Kinesis Data Streams 的應用程式KCL。透過在低階 Kinesis Data Streams 上方提供有用的抽象, KCL 可簡化編碼API。如需 的詳細資訊KCL,請參閱《Amazon Kinesis Kinesis Data Streams 開發人員指南》中的使用 Kinesis 用戶端程式庫開發消費者

目前 1.x KCL版與 AWS SDK for Java v1.x 版在生命週期中將持續獲得完全支援,以確保穩定性和效能。如果您使用的是現有的 SDK,則在過渡期間,使用 AWS SDK for Java v1.x 的現有應用程式將繼續如預期運作,以符合 AWS SDKs和 工具維護政策

身為 DynamoDB Streams 使用者,您可以使用 中發現的設計模式KCL來處理 DynamoDB Streams 碎片和串流記錄。為此,您可以使用 DynamoDB Streams Kinesis 轉接器。Kinesis Adapter 會實作 Kinesis Data Streams 介面,以便 KCL 可用來取用和處理來自 DynamoDB Streams 的記錄。如需如何設定和安裝 DynamoDB Streams Kinesis Adapter 的指示,請參閱儲存GitHub庫

下圖顯示這些程式庫彼此如何互動。

DynamoDB Streams、Kinesis Data Streams 和 之間的互動KCL,用於處理 DynamoDB Streams 記錄。

使用 DynamoDB Streams Kinesis Adapter,您可以開始針對KCL界面進行開發,並將API呼叫無縫導向 DynamoDB Streams 端點。

當您的應用程式啟動時,它會呼叫 KCL來執行個體化工作者。您必須向工作者提供應用程式的組態資訊,例如串流描述項和 AWS 登入資料,以及您提供的記錄處理器類別名稱。當其在紀錄處理器中執行程式碼時,工作者會執行下列任務:

  • 連線到串流

  • 列舉串流內的碎片

  • 與其他工作者 (若有) 協調碎片關聯性

  • 為其所管理的每個碎片執行個體化記錄處理器

  • 從串流提取紀錄

  • 將記錄推送至對應的記錄處理器

  • 對已處理的記錄執行檢查點作業

  • 當工作者執行個體數目變更時,平衡碎片與工作者的關聯

  • 當碎片進行分割時,平衡碎片與工作者的關聯

注意

如需此處所列KCL概念的描述,請參閱《Amazon Kinesis Kinesis Data Streams 開發人員指南》中的使用 Kinesis 用戶端程式庫開發消費者

如需搭配 使用串流的詳細資訊, AWS Lambda 請參閱 DynamoDB 串流和 AWS Lambda 觸發

隱私權網站條款Cookie 偏好設定
© 2025, Amazon Web Services, Inc.或其附屬公司。保留所有權利。