对象存储服务 OBS-分段上传:列举已上传的段

时间：2024-10-23 16:33:02

对象存储服务 OBS

列举已上传的段

您可使用ObsClient.listParts列举出某一分段上传任务所有已经上传成功的段。

该接口可设置的参数如下：

参数	作用	OBS Android SDK对应方法
bucketName	分段上传任务所属的桶名。	ListPartsRequest.setBucketName
key	分段上传任务所属的对象名。	ListPartsRequest.setKey
uploadId	分段上传任务全局唯一标识，从ObsClient.initiateMultipartUpload返回的结果获取。	ListPartsRequest.setUploadId
maxParts	表示列举已上传的段返回结果最大段数目，即分页时每一页中段数目。	ListPartsRequest.setMaxParts
partNumberMarker	表示待列出段的起始位置，只有Part Number大于该参数的段会被列出。	ListPartsRequest.setPartNumberMarker

简单列举

// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量AC CES S_KEY_ID和SECRET_ACCESS_KEY_ID。
// 您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
String ak = System.getenv("ACCESS_KEY_ID");
String sk = System.getenv("SECRET_ACCESS_KEY_ID");
String endPoint = "https://your-endpoint";
String uploadId = "upload id from initiateMultipartUpload";
// 创建ObsClient实例
ObsClient obsClient = new ObsClient(ak, sk, endPoint);

//列举已上传的段，其中uploadId来自于initiateMultipartUpload        
ListPartsRequest request = new ListPartsRequest("bucketname", "objectname");
request.setUploadId(uploadId);
ListPartsResult result = obsClient.listParts(request);

for(Multipart part : result.getMultipartList()){
    // 分段号，上传时候指定
   Log.i("ListParts", "\t"+part.getPartNumber());
    // 段数据大小
   Log.i("ListParts","\t"+part.getSize());
    // 分段的ETag值
   Log.i("ListParts","\t"+part.getEtag());
    // 段的最后上传时间
   Log.i("ListParts","\t"+part.getLastModified());
}

列举段至多返回1000个段信息，如果指定的Upload ID包含的段数量大于1000，则返回结果中ListPartsResult.isTruncated为true表明本次没有返回全部段，并可通过ListPartsResult.getNextPartNumberMarker获取下次列举的起始位置。
如果想获取指定Upload ID包含的所有分段，可以采用分页列举的方式。

列举所有段

由于ObsClient.listParts只能列举至多1000个段，如果段数量大于1000，列举所有分段请参考如下示例：

// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量ACCESS_KEY_ID和SECRET_ACCESS_KEY_ID。
// 您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
String ak = System.getenv("ACCESS_KEY_ID");
String sk = System.getenv("SECRET_ACCESS_KEY_ID");
String endPoint = "https://your-endpoint";
String uploadId = "upload id from initiateMultipartUpload";
// 创建ObsClient实例
ObsClient obsClient = new ObsClient(ak, sk, endPoint);

// 列举所有已上传的段，其中uploadId来自于initiateMultipartUpload        
ListPartsRequest request = new ListPartsRequest("bucketname", "objectname");
request.setUploadId(uploadId);
ListPartsResult result;

do{
    result = obsClient.listParts(request);
    for(Multipart part : result.getMultipartList()){
        // 分段号，上传时候指定
       Log.i("ListParts","\t"+part.getPartNumber());
        // 段数据大小
       Log.i("ListParts","\t"+part.getSize());
        // 分段的ETag值
       Log.i("ListParts","\t"+part.getEtag());
        // 段的最后上传时间
       Log.i("ListParts","\t"+part.getLastModified());
    }
    request.setPartNumberMarker(Integer.parseInt(result.getNextPartNumberMarker()));
}while(result.isTruncated());