创建通道

前提条件

• 已初始化TunnelClient。

• 已创建数据表。具体操作，请参见创建数据表。

参数

示例

以下示例用于为数据表创建一个全量加增量类型的通道。

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。

• 如果要快速使用通道服务消费数据，请参见快速使用通道服务文档进行操作。

• 如果要查看指定表的所有通道信息，您可以通过获取表内的通道信息实现。更多信息，请参见获取表内的通道信息。

• 如果要查看指定通道的详细信息，您可以通过获取通道的具体信息实现。更多信息，请参见获取通道的具体信息。

• 如果不再使用某个通道，您可以删除相应通道。更多信息，请参见删除通道。

• 使用通道服务可以实现数据迁移。更多信息，请参见将表格存储数据表中数据同步到另一个数据表或将表格存储时序表中数据同步到另一个时序表。

• 实时计算Flink能将通道服务的数据通道作为流式数据的输入，可实现通过Flink计算与分析表格存储数据，更多信息，请参见使用教程（宽表模型）和使用教程（时序模型）。

• 当前通道服务本身没有额外的费用开销。在消费通道服务数据时，表格存储会根据实际拉取的数据产生读吞吐量计量计费。更多信息，请参见计费概述。