文档首页 > > SDK参考> 使用SDK> 使用SDK(Python)> 新增Checkpoint

新增Checkpoint

分享
更新时间: 2019/11/22 GMT+08:00

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

代码样例参考“commitCheckpoint_sample.py”文件,配置参数如下:

1
2
3
4
5
streamname = "" #通道名称
appName="xx"      # APP名称(APP是已存在状态)
partitionId="shardId-0000000000"   #分区的唯一标识符。
seqNumber="0"  #序列号
metadata=""   #用户消费程序端的元数据信息,元数据信息的最大长度为1000个字符

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

配置好以上参数,执行commitCheckpoint_sample.py文件调用commitCheckpoint_test方法,响应201表示成功。

分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问