在表格存储管理控制台快速体验通道服务功能。
创建数据通道
预览通道中的数据格式
创建通道后,通过模拟数据消费可以预览通道中的数据格式。
- 写入或删除数据,详情请参见控制台读写数据。
- 预览通道中的数据格式。
开启通道的数据消费
- 在通道列表中复制通道ID。
- 使用任一语言的通道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 { //模拟消费处理。 Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } @Override public void shutdown() { System.out.println("Mock shutdown"); } } //强烈建议共用一个TunnelWorkerConfig,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接口也可以查看消费延迟、通道分区下的消费数据行数更新。