如果需要即時消費表中資料,您需要調用CreateTunnel介面為資料表建立一個通道,一張資料表上可以建立多個通道。在建立通道時需要指定資料表名稱、通道名稱和通道類型。
前提條件
已初始化TunnelClient。
已建立資料表。具體操作,請參見建立資料表。
參數
請求參數
參數 | 說明 |
TableName | 建立通道的資料表名稱。 |
TunnelName | 通道的名稱。 |
Type | 通道的類型,支援全量(BaseData)、增量(Stream)和全量加增量(BaseAndStream)三種。 建立增量或者全量加增量類型的通道時,系統預設建立通道後寫入的資料為增量資料。如果要消費指定時間點後的增量資料,請配置增量資料的起始時間戳記(startTime)。
|
響應參數
參數 | 說明 |
TunnelId | 通道的ID。 |
ResponseInfo | 返回的一些其它欄位,包括當次請求的RequestId。RequestId用於唯一標識此次請求。 |
樣本
以下樣本用於為資料表建立一個全量加增量類型的通道。
req := &tunnel.CreateTunnelRequest{
TableName: "<TABLE_NAME>",
TunnelName: "<TUNNEL_NAME>",
Type: tunnel.TunnelTypeBaseStream, //建立全量加增量類型的Tunnel。
}
resp, err := tunnelClient.CreateTunnel(req)
if err != nil {
log.Fatal("create tunnel failed ", err)
}
log.Println("tunnel id is", resp.TunnelId)
常見問題
使用通道服務消費資料時報錯OTSTrimmedDataAccess Requested stream data is already trimmed or does not exist
相關文檔
關於API說明的更多資訊,請參見CreateTunnel。
如果要快速使用通道服務消費資料,請參見快速使用通道服務文檔進行操作。
如果要查看指定表的所有通道資訊,您可以通過擷取表內的通道資訊實現。更多資訊,請參見擷取表內的通道資訊。
如果要查看指定通道的詳細資料,您可以通過擷取通道的具體資訊實現。更多資訊,請參見擷取通道的具體資訊。
如果不再使用某個通道,您可以刪除相應通道。更多資訊,請參見刪除通道。
使用通道服務可以實現資料移轉。更多資訊,請參見將Table Store資料表中資料同步到另一個資料表。
Realtime ComputeFlink能將通道服務的資料通道作為流式資料的輸入,可實現通過Flink計算與分析Table Store資料,更多資訊,請參見使用教程(寬表模型)和使用教程(時序模型)。
當前通道服務本身沒有額外的費用開銷。在消費通道服務資料時,Table Store會根據實際拉取的資料產生讀輸送量計量計費。更多資訊,請參見計費概述。