您可以在表格存储管理控制台快速体验通道服务(Tunnel Service)功能。

前提条件

您已经开通表格存储服务

创建数据通道

  1. 登录表格存储控制台
  2. 进找到目标数据表,然后在该数据表的右侧单击通道管理
  3. 在管理通道页面的右上角,单击创建通道
  4. 在弹出的创建通道窗口,输入通道名称,并选择通道类型

    通道服务为您提供了增量全量增量加全量三种类型的分布式数据实时消费通道。本文档中以增量类型为例。



    创建成功后,您可以在管理通道页面查看通道中的数据内容、消费延迟监控、通道分区下的消费数据行数统计。

预览通道中的数据格式

  1. 在控制台数据管理页面随机写入或删除数据。

  2. 返回管理通道页面,找到新创建的通道,在其右侧单击展示通道分区列表,页面底部会显示该通道的通道分区列表。

  3. 在通道分区的右侧单击模拟消费。在弹出的页面中可以预览通道中的数据格式。

开启通道的数据消费

  1. 在通道列表中复制通道ID。

  2. 使用任一语言的通道SDK,开启通道的数据消费。
    // 用户自定义数据消费Callback, 即实现IChannelProcessor接口(process和shutdown)
    private static class SimpleProcessor implements IChannelProcessor {
        @Override
        public void process(ProcessRecordsInput input) {
            System.out.println("Default record processor, would print records count");
            System.out.println(
                String.format("Process %d records, NextToken: %s", input.getRecords().size(), input.getNextToken()));
            try {
                // Mock Record Process.
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        @Override
        public void shutdown() {
            System.out.println("Mock shutdown");
        }
    }
    
    // TunnelWorkerConfig里面还有更多的高级参数,这里不做展开,会有专门的文档介绍。
    TunnelWorkerConfig config = new TunnelWorkerConfig(new SimpleProcessor());
    // 配置TunnelWorker,并启动自动化的数据处理任务。
    TunnelWorker worker = new TunnelWorker($tunnelId, tunnelClient, config);
    try {
        worker.connectAndWorking();
    } catch (Exception e) {
        e.printStackTrace();
        worker.shutdown();
        tunnelClient.shutdown();
    }

查看数据消费日志

在数据消费标准输出可以看到增量数据消费日志,在控制台或者使用describeTunnel接口也可以查看消费延迟、通道分区下的消费数据行数更新。