更新时间:2024-10-25 GMT+08:00
分享

新增Checkpoint

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

配置参数如下:

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

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

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

相关文档