通道服务快速入门

在表格存储管理控制台快速体验通道服务功能。

操作步骤

步骤一:创建数据通道

  1. 进入实时消费通道页面。

    1. 登录表格存储控制台

    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

通过命令行工具