更新时间:2021-07-27 GMT+08:00
查询Checkpoint
参见初始化DIS客户端的操作初始化一个DIS客户端实例。
配置参数如下:
1 2 3 | streamname = "" #通道名称
appName="xx" # APP名称(APP是已存在状态)
partitionId="shardId-0000000000" #分区的唯一标识符
|
配置好以上参数,执行getCheckpoint_sample.py文件调用getCheckpoint_test方法,响应结果如下:
1 2 3 4 | {
"sequence_number": "10",
"metadata": "metadata"
}
|
父主题: 使用SDK(Python)
