文档首页 > > SDK参考> 使用SDK> 使用SDK(Python)> 添加转储任务

添加转储任务

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

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

代码样例参考“add_dump_task_sample.py”文件,参照添加转储任务配置方法中的参数值。

配置如下参数:
streamname='dis—test1'  #已存在的通道名
task_name='113'

添加OBS转储服务为例:value参数值设定与key对应

basic_Schema=DumpTask.setSchema(key=['consumer_strategy','deliver_time_int       erval','agency_name','retry_duration'],
      value=['LATEST', 30, 'dis_admin_agency',1800])
obs_dump_task =['destination_file_type','obs_bucket_path','file_prefix', 'partition_format','record_delimiter']
obs_Schema = DumpTask.setSchema(basic_Schema=basic_Schema,
                key=obs_dump_task,value=['text','obs-1253', '','yyyy', '|'])

# 添加OBS转储服务,配置osb_Schema值

  cli.add_dump_task(streamname, task_name,'OBS',obs_Schema)
  • 配置好以上参数后,执行add_dump_task_sample.py文件默认调用add_dump_task_test方法,获取响应201创建成功。

分享:

    相关文档

    相关产品

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

提交成功!

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

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

*必选

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

字符长度不能超过200

提交反馈 取消

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

跳转到云社区