数据接入服务 DIS
数据接入服务 DIS
- 最新动态
- 产品介绍
- 快速入门
- 用户指南
- 最佳实践
- API参考
- SDK参考
- 常见问题
- 文档下载
- 通用参考
本文导读
展开导读
链接复制成功!
添加转储任务
参见初始化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)
父主题: 使用SDK(Python)