数据接入服务 DIS-查询Checkpoint

时间:2025-02-12 14:55:05

查询Checkpoint

参见初始化DIS客户端的操作初始化一个DIS客户端实例。

配置参数如下:

123
streamname = "" #通道名称appName="xx"      # APP名称(APP是已存在状态)partitionId="shardId-0000000000"  #分区的唯一标识符

partitionId可通过查询通道详情获取,需要先传入当前设置的通道名称。

配置好以上参数,执行getCheckpoint_sample.py文件调用getCheckpoint_test方法,响应结果如下:

1234
{    "sequence_number": "10",   "metadata": "metadata"   }

support.huaweicloud.com/sdkreference-dis/dis_06_0053.html