全部文档
当前文档
最近更新时间：2025-08-20 20:02:36
以下代码用于列举批量处理任务：
public void listJobs() {
// 初始化 Ks3Client，参见“初始化”文档
Ks3Client ks3Client = initKs3Client();
try {
// 创建 ListJobsRequest 对象
ListJobsRequest request = new ListJobsRequest();
// 设置查询的任务状态列表
request.setStatusList(Arrays.asList(JobStatus.NEW, JobStatus.ACTIVE));
// 设置最大返回结果数
request.setMaxResults(1000);
while (true) {
// 发送请求
ListJobsResult listJobsResult = ks3Client.listJobs(request);
// 打印结果
for (JobSummary jobSummary : listJobsResult.getJobSummaryList()) {
System.out.println("JobId: " + jobSummary.getJobId());
System.out.println("Description: " + jobSummary.getDescription());
System.out.println("Status: " + jobSummary.getStatus());
System.out.println("Operation: " + jobSummary.getOperation());
System.out.println("CreationTime: " + jobSummary.getCreationTime());
System.out.println("TerminationDate: " + jobSummary.getTerminationDate());
System.out.println("Priority: " + jobSummary.getPriority());
System.out.println("ProgressSummary: " + jobSummary.getProgressSummary());
}
// 如果没有下一页，结束循环
if (StringUtils.isBlank(listJobsResult.getNextToken())) {
break;
}
// 设置下一个 token
request.setNextToken(listJobsResult.getNextToken());
}
} catch (Ks3ServiceException e) {
System.out.println("Ks3ServiceException occurred, which means the request was made to KS3, but KS3 returned an error response for some reason.");
System.out.println("Error Message: " + e.getErrorMessage());
System.out.println("Error Code: " + e.getErrorCode());
System.out.println("Request ID: " + e.getRequestId());
} catch (Ks3ClientException e) {
System.out.println("Ks3ClientException occurred, which means the client encountered an internal error while trying to communicate with KS3.");
System.out.println("Error Message: " + e.getMessage());
} finally {
// 不再使用时，关闭 Ks3Client
ks3Client.shutdown();
}
}纯净模式