Tablestore：快速入門

建立資料通道

1. 登入Table Store控制台。

2. 在概覽頁面，單擊執行個體名稱或在操作列單擊執行個體管理。

3. 在執行個體詳情頁簽的資料表列表地區，單擊資料表名稱後選擇即時消費通道頁簽或單擊後選擇即時消費通道。

4. 在即時消費通道頁簽，單擊建立通道。

5. 在建立通道對話方塊，輸入通道名，並選擇通道類型。

   通道服務提供了增量、全量、全量加增量三種類型的分布式資料即時消費通道。本文以全量加增量類型為例介紹。

   建立成功後，在操作列單擊展示通道分區列表，可以查看通道中的資料內容、消費延遲監控以及通道分區下的消費資料行數統計。

預覽通道中的資料格式

建立通道後，通過類比資料消費可以預覽通道中的資料格式。

1. 寫入或刪除資料，詳情請參見控制台讀寫資料。

2. 預覽通道中的資料格式。

   1. 在概覽頁頁面，單擊執行個體名稱或在操作列單擊執行個體管理。

   2. 在執行個體詳情頁簽的資料表列表地區，單擊資料表名稱後選擇即時消費通道頁簽或單擊後選擇即時消費通道。

   3. 在即時消費通道頁簽，單擊通道操作列的展示通道分區列表。

   4. 在通道分區的右側單擊類比消費。

   5. 在類比消費對話方塊，單擊開始消費。

      消費的資料資訊顯示在對話方塊中，如下圖所示。

開啟通道的資料消費

1. 在通道列表中複製通道ID。

2. 使用任一種語言的通道SDK，開啟通道的資料消費。

   此處以Java SDK為例開啟通道的資料消費。

   import com.alicloud.openservices.tablestore.TunnelClient;
   import com.alicloud.openservices.tablestore.tunnel.worker.IChannelProcessor;
   import com.alicloud.openservices.tablestore.tunnel.worker.ProcessRecordsInput;
   import com.alicloud.openservices.tablestore.tunnel.worker.TunnelWorker;
   import com.alicloud.openservices.tablestore.tunnel.worker.TunnelWorkerConfig;
   
   public class TunnelQuickStart {
   
       /**
        * 使用者自訂資料消費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");
           }
       }
   
       public static void main(String[] args) {
           // 1. 初始化Tunnel Client。
           TunnelClient tunnelClient = new TunnelClient("<ENDPOINT>", "<ACCESS_ID>", "<ACCESS_KEY>", "<INSTANCE_NAME>");
   
           // 2. 使用者自訂資料消費Callback, 開始自動化的資料消費。
           //強烈建議共用一個TunnelWorkerConfig，TunnelWorkerConfig中包括更多的進階參數。
           TunnelWorkerConfig config = new TunnelWorkerConfig(new SimpleProcessor());
           //配置TunnelWorker，並啟動自動化的資料處理任務。
           //TUNNEL_ID，通道id。
           TunnelWorker worker = new TunnelWorker("<TUNNEL_ID>", tunnelClient, config);
           try {
               worker.connectAndWorking();
           } catch (Exception e) {
               e.printStackTrace();
               worker.shutdown();
               tunnelClient.shutdown();
           }
       }
   }

查看資料消費日誌

資料消費後，可以查看增量資料消費日誌，例如消費統計、增量通道分區最新同步時間等。在控制台或者使用describeTunnel介面也可以查看消費延遲、通道分區下的消費資料行數更新。