文档首页 > > SDK参考> 使用SDK> 使用SDK(C#)> 新增CheckPoint

新增CheckPoint

分享
更新时间: 2019/05/07 GMT+08:00

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

使用DIS SDK新增CheckPoint。

string appName= “appName”;
var dic = new DISIngestionClient();
         var request = new CommitCheckpointRequest
            {
            //通道名称
                stream_name = streamName,
            //APP的名称
                AppName = appName,
            //分区的唯一标识符
                partition_id = "shardId-0000000000",
           //序列号
                sequence_number = "10",
           //用户消费程序端的元数据信息
                metadata = "metadata",
          //Checkpoint类型
                checkpoint_type = "LAST_READ",
            };

            var response = dic.CommitCheckpoint(request);
            Console.Out.WriteLine(response);

运行结果

可以在控制台查看到类似如下信息:

{ResponseResult{status_code='201 Created', content='', errorCode='', message=''}}
表1 ResponseResult响应参数说明

参数名

类型

说明

content

String

响应消息体

errorCode

String

错误码

message

String

错误响应消息体

status_code

String

状态码

分享:

    相关文档

    相关产品

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

提交成功!

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

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

*必选

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

字符长度不能超过200

提交反馈 取消

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

智能客服提问云社区提问