表格存储的Go SDK提供了通道服务的多个接口封装。接口封装包括管控接口和自动化的数据消费框架两部分。
快速使用
使用通道服务实时消费数据前,您需要为数据表创建通道,然后通过通道消费表中数据。具体操作,请参见快速体验通道服务。
管控接口
为数据表创建通道时,您需要指定数据表名称、通道名称和通道类型。具体操作,请参见创建通道。
创建通道后,您可以根据实际管理通道。
功能特性 | 说明 |
列举某个数据表内通道的具体信息。 | |
描述某个通道里的具体Channel信息。目前一个Channel对应TableStore Stream接口的一个数据分片。 | |
删除指定数据表的一个通道。 |
数据消费框架
自动化的数据消费框架的实现流程是Tunnel Client通过每一轮的定时心跳探测(Heartbeat)进行活跃Channel的探测,Channel和ChannelConnect状态的更新,以及数据处理任务的初始化、运行和结束等。
Tunnel Client可以解决全量和增量数据处理时的常见问题,例如负载均衡、故障恢复、Checkpoint、分区信息同步确保分区信息消费顺序等。使用Tunnel Client后,您只需要关心每条记录的处理逻辑。更多信息,请参见数据消费框架原理介绍。
相关文档
关于通道服务的更多信息,请参见通道服务。
使用通道服务可以实现数据迁移。更多信息,请参见将表格存储数据表中数据同步到另一个数据表。
实时计算Flink能将通道服务的数据通道作为流式数据的输入,可实现通过Flink计算与分析表格存储数据,更多信息,请参见使用教程(宽表模型)和使用教程(时序模型)。
当前通道服务本身没有额外的费用开销。在消费通道服务数据时,表格存储会根据实际拉取的数据产生读吞吐量计量计费。更多信息,请参见计费概述。