全部產品
Search
文件中心

Tablestore:通道服務快速入門

更新時間:May 01, 2025

在Table Store管理主控台快速體驗通道服務功能。

操作步驟

步驟一:建立資料通道

  1. 進入即時消費通道頁面。

    1. 登入Table Store控制台

    2. 在頁面上方,選擇資源群組和地區。

    3. 概覽頁面,單擊執行個體名稱或者單擊執行個體操作列的執行個體管理

    4. 執行個體詳情頁簽下的資料表列表頁簽,單擊資料表名稱後選擇即時消費通道頁簽或單擊fig_001後選擇即時消費通道

  2. 即時消費通道頁簽,單擊建立通道

  3. 建立通道對話方塊,按照下表說明配置通道資訊。

    參數

    說明

    通道名

    通道的名稱。

    通道類型

    通道的類型。取值範圍如下:

    • 全量:只能消費處理全量資料。

    • 增量:只能消費處理增量資料。

    • 全量加增量:全量資料消費處理完成後,再消費處理增量資料。

    起始時間

    建立增量或者全量加增量類型的通道時,系統預設建立通道後寫入的資料為增量資料。如果要消費指定時間點後的增量資料,請配置增量資料的起始時間。您也可以按需配置增量資料的結束時間。

    起始時間和結束時間的取值範圍均為[當前系統時間-Stream到期時間+5分鐘 , 當前系統時間],格式為64位時間戳記,單位為毫秒。結束時間的取值必須大於起始時間。

    重要

    Stream到期時間為增量日誌到期時間長度的毫秒單位時間戳記,最大值為7天。您可以在為資料表開啟Stream功能時設定,到期時間長度一經設定不能修改。

    結束時間

  4. 單擊確定

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

    image

步驟二:(可選)預覽通道中的資料格式

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

  1. 在表中寫入資料刪除資料

  2. 在表的即時消費通道頁簽,單擊通道右側的展示通道分區列表

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

  4. 類比消費對話方塊,單擊開始消費

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

    image

    消費資料的格式樣本

    消費資料的格式樣本如下:

    {
      "sequenceInfo": {
        "epoch": 0,
        "rowIndex": 0,
        "timestamp": 0
      },
      "recordType": "PUT",
      "columns": [
        {
          "actionType": "PUT",
          "name": "create_time",
          "type": "STRING",
          "value": "2024-02-18 22:10:07"
        },
        {
          "actionType": "PUT",
          "name": "modified_time",
          "type": "STRING",
          "value": "2024-02-18 22:10:07"
        },
        {
          "actionType": "PUT",
          "name": "num",
          "type": "INTEGER",
          "value": 29
        },
        {
          "actionType": "PUT",
          "name": "order_status",
          "type": "STRING",
          "value": "00"
        },
        {
          "actionType": "PUT",
          "name": "price",
          "type": "DOUBLE",
          "value": 400
        },
        {
          "actionType": "PUT",
          "name": "sku_id",
          "type": "STRING",
          "value": "9000000007"
        },
        {
          "actionType": "PUT",
          "name": "total_price",
          "type": "DOUBLE",
          "value": 11600
        },
        {
          "actionType": "PUT",
          "name": "user_id",
          "type": "STRING",
          "value": "1000000042"
        }
      ],
      "primaryKey": [
        {
          "name": "order_id",
          "type": "STRING",
          "value": "90fb478c-1360-11f0-a34d-00163e30a2a9"
        }
      ],
      "timestamp": 0
    }

步驟三:開啟通道的資料消費

  1. 即時消費通道頁簽的通道列表中複製通道ID。

  2. 通過Java SDKGo SDK快速使用通道消費資料。

    資料消費後,您可以查看增量資料消費日誌,例如消費統計、增量通道分區最新同步時間等。在控制台也可以查看消費延遲、通道分區下的消費資料行數。

開發整合

您可以使用命令列工具或SDK進行通道操作。

功能

調用方式

建立通道

通過SDK:JavaGo

通過命令列工具

擷取表內的通道資訊

通過SDK:JavaGo

通過命令列工具

擷取通道的具體資訊

通過SDK:JavaGo

通過命令列工具

類比通道消費

通過命令列工具

刪除通道

通過SDK:JavaGo

通過命令列工具