Table Store的Go SDK提供了通道服務的多個介面封裝。介面封裝包括管控介面和自動化的資料消費架構兩部分。
快速使用
使用通道服務即時消費資料前,您需要為資料表建立通道,然後通過通道消費表中資料。具體操作,請參見快速體驗通道服務。
管控介面
為資料表建立通道時,您需要指定資料表名稱、通道名稱和通道類型。具體操作,請參見建立通道。
建立通道後,您可以根據實際管理通道。
功能特性 | 說明 |
列舉某個資料表內通道的具體資訊。 | |
描述某個通道裡的具體Channel資訊。目前一個Channel對應TableStore Stream介面的一個資料分區。 | |
刪除指定資料表的一個通道。 |
資料消費架構
自動化的資料消費架構的實現流程是Tunnel Client通過每一輪的定時心跳探測(Heartbeat)進行活躍Channel的探測,Channel和ChannelConnect狀態的更新,以及資料處理任務的初始化、運行和結束等。
Tunnel Client可以解決全量和增量資料處理時的常見問題,例如負載平衡、故障恢複、Checkpoint、分區資訊同步確保分區資訊消費順序等。使用Tunnel Client後,您只需要關心每條記錄的處理邏輯。更多資訊,請參見資料消費架構原理介紹。
相關文檔
關於通道服務的更多資訊,請參見通道服務。
使用通道服務可以實現資料移轉。更多資訊,請參見將Table Store資料表中資料同步到另一個資料表。
Realtime ComputeFlink能將通道服務的資料通道作為流式資料的輸入,可實現通過Flink計算與分析Table Store資料,更多資訊,請參見使用教程(寬表模型)和使用教程(時序模型)。
當前通道服務本身沒有額外的費用開銷。在消費通道服務資料時,Table Store會根據實際拉取的資料產生讀輸送量計量計費。更多資訊,請參見計費概述。