創(chuàng)建通道
如果需要實時消費表中數(shù)據(jù)，您需要調(diào)用CreateTunnel接口為數(shù)據(jù)表創(chuàng)建一個通道，一張數(shù)據(jù)表上可以創(chuàng)建多個通道。在創(chuàng)建通道時需要指定數(shù)據(jù)表名稱、通道名稱和通道類型。
前提條件
已初始化TunnelClient。
已創(chuàng)建數(shù)據(jù)表。具體操作，請參見創(chuàng)建數(shù)據(jù)表。
參數(shù)
請求參數(shù)
參數(shù) | 說明 |
TableName | 創(chuàng)建通道的數(shù)據(jù)表名稱。 |
TunnelName | 通道的名稱。 |
Type | 通道的類型，支持全量（BaseData）、增量（Stream）和全量加增量（BaseAndStream）三種。 創(chuàng)建增量或者全量加增量類型的通道時，系統(tǒng)默認(rèn)創(chuàng)建通道后寫入的數(shù)據(jù)為增量數(shù)據(jù)。如果要消費指定時間點后的增量數(shù)據(jù)，請配置增量數(shù)據(jù)的起始時間戳（startTime）。
|
響應(yīng)參數(shù)
參數(shù) | 說明 |
TunnelId | 通道的ID。 |
ResponseInfo | 返回的一些其它字段，包括當(dāng)次請求的RequestId。RequestId用于唯一標(biāo)識此次請求。 |
示例
以下示例用于為數(shù)據(jù)表創(chuàng)建一個全量加增量類型的通道。
req := &tunnel.CreateTunnelRequest{
TableName: "<TABLE_NAME>",
TunnelName: "<TUNNEL_NAME>",
Type: tunnel.TunnelTypeBaseStream, //創(chuàng)建全量加增量類型的Tunnel。
}
resp, err := tunnelClient.CreateTunnel(req)
if err != nil {
log.Fatal("create tunnel failed ", err)
}
log.Println("tunnel id is", resp.TunnelId)常見問題
相關(guān)文檔
關(guān)于API說明的更多信息，請參見CreateTunnel。
如果要快速使用通道服務(wù)消費數(shù)據(jù)，請參見快速使用通道服務(wù)文檔進行操作。
如果要查看指定表的所有通道信息，您可以通過獲取表內(nèi)的通道信息實現(xiàn)。更多信息，請參見獲取表內(nèi)的通道信息。
如果要查看指定通道的詳細(xì)信息，您可以通過獲取通道的具體信息實現(xiàn)。更多信息，請參見獲取通道的具體信息。
如果不再使用某個通道，您可以刪除相應(yīng)通道。更多信息，請參見刪除通道。
使用通道服務(wù)可以實現(xiàn)數(shù)據(jù)遷移。更多信息，請參見將表格存儲數(shù)據(jù)表中數(shù)據(jù)同步到另一個數(shù)據(jù)表或將表格存儲時序表中數(shù)據(jù)同步到另一個時序表。
實時計算Flink能將通道服務(wù)的數(shù)據(jù)通道作為流式數(shù)據(jù)的輸入，可實現(xiàn)通過Flink計算與分析表格存儲數(shù)據(jù)，更多信息，請參見使用教程（寬表模型）和使用教程（時序模型）。
當(dāng)前通道服務(wù)本身沒有額外的費用開銷。在消費通道服務(wù)數(shù)據(jù)時，表格存儲會根據(jù)實際拉取的數(shù)據(jù)產(chǎn)生讀吞吐量計量計費。更多信息，請參見計費概述。