添加转储任务

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

参照配置方法中的参数值。

配置如下参数：
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转储服务,配置obs_Schema值

  cli.add_dump_task(streamname, task_name,'OBS',obs_Schema)

• 配置好以上参数后，执行add_dump_task_sample.py文件默认调用add_dump_task_test方法，获取响应201创建成功。