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

更新转储任务

参考初始化DIS客户端的操作初始化一个DIS客户端实例,实例名称为dic。

使用DIS SDK更新转储任务,需要指定通道名称、转储任务名称,转储周期,转储目标服务等信息。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
//需配置转储任务的全量参数,不支持更新单个参数
UpdateTransferTaskRequest request = new UpdateTransferTaskRequest();

// 配置待更新的转储任务所属通道的名称
request.setStreamName(streamName);

// 配置待更新的转储任务名称
OBSDestinationDescriptorRequest descriptor = new OBSDestinationDescriptorRequest();
descriptor.setTransferTaskName(taskName);

// 转储至对象存储服务(简称OBS):OBS桶名和子文件夹名,通过OBS控制台或客户端创建桶和文件夹
descriptor.setObsBucketPath("obs-dis1");
descriptor.setFilePrefix("transfertask");

// 转储周期,单位s
descriptor.setDeliverTimeInterval(300);

// 可选,转储OBS的目标文件格式:默认text,可配置parquet、carbon
descriptor.setDestinationFileType(DestinationFileTypeEnum.TEXT.getType());

request.setObsDestinationDescriptor(descriptor);

配置“UpdateTransferTaskRequest”对象之后,通过调用updateTransferTask的方法更新转储任务。

1
dic.updateTransferTask(request);

相关文档