通道服务

更新时间:2025-01-13 02:21

表格存储的Go SDK提供了通道服务的多个接口封装。接口封装包括管控接口和自动化的数据消费框架两部分。

快速使用

使用通道服务实时消费数据前,您需要为数据表创建通道,然后通过通道消费表中数据。具体操作,请参见快速体验通道服务

管控接口

为数据表创建通道时,您需要指定数据表名称、通道名称和通道类型。具体操作,请参见创建通道

创建通道后,您可以根据实际管理通道。

功能特性

说明

功能特性

说明

获取表内的通道信息

列举某个数据表内通道的具体信息。

获取通道的具体信息

描述某个通道里的具体Channel信息。目前一个Channel对应TableStore Stream接口的一个数据分片。

删除通道

删除指定数据表的一个通道。

数据消费框架

自动化的数据消费框架的实现流程是Tunnel Client通过每一轮的定时心跳探测(Heartbeat)进行活跃Channel的探测,Channel和ChannelConnect状态的更新,以及数据处理任务的初始化、运行和结束等。

Tunnel Client可以解决全量和增量数据处理时的常见问题,例如负载均衡、故障恢复、Checkpoint、分区信息同步确保分区信息消费顺序等。使用Tunnel Client后,您只需要关心每条记录的处理逻辑。更多信息,请参见数据消费框架原理介绍

相关文档

  • 关于通道服务的更多信息,请参见通道服务

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

  • 实时计算Flink能将通道服务的数据通道作为流式数据的输入,可实现通过Flink计算与分析表格存储数据,更多信息,请参见使用Flink

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

  • 本页导读 (1)
  • 快速使用
  • 管控接口
  • 数据消费框架
  • 相关文档
文档反馈