更新时间:2026-07-24 GMT+08:00
上传对象后如何确认上传是否成功?
本文为您介绍,通过控制台、OBS Browser+、obsutil、SDK上传对象时,如何确认上传对象是否成功。
SDK上传对象
上传对象后,您可以通过以下方式判断对象是否上传成功:
- 方式1:判断上传请求的返回码。返回200代表上传成功,没有返回200代表上传失败。
- 方式2:上传后获取对象元数据。如果能查询到对象元数据,代表上传成功;如果查询不到对象元数据,代表上传失败。了解更多请参考配置、编辑、查看对象元数据。
对于分段上传来说,上传一个完整的对象涉及多个请求,单个请求返回200并不代表上传对象成功。因此,建议在执行完所有分段上传操作后,使用“方式2:获取对象元数据”的方法确认上传是否成功。
Java示例代码
向名为examplebucket的桶中上传名为exampleobject的对象,然后查看对象元数据:
import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException;
import com.obs.services.model.ObjectMetadata;
import com.obs.services.model.PutObjectRequest;
import com.obs.services.model.PutObjectResult;
import java.io.File;
public class ObsUploadVerification {
public static void main(String[] args) {
// 您可以通过环境变量获取访问密钥AK/SK,也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥AK/SK
String ak = System.getenv("ACCESS_KEY_ID");
String sk = System.getenv("SECRET_ACCESS_KEY_ID");
// 【可选】如果使用临时AK/SK和SecurityToken访问OBS,同样建议您尽量避免使用硬编码,以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥AK/SK/SecurityToken,也可以使用其他外部引入方式传入。
// String securityToken = System.getenv("SECURITY_TOKEN");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例,其他地区请按实际情况填写。
String endPoint = "https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endPoint,也可以使用其他外部引入方式传入。
//String endPoint = System.getenv("ENDPOINT");
String bucketName = "examplebucket";
String objectKey = "exampleobject";
File localFile = new File("localfile.txt");
// 创建ObsClient实例
// 使用永久AK/SK初始化客户端
ObsClient obsClient = new ObsClient(ak, sk, endPoint);
// 使用临时AK/SK和SecurityToken初始化客户端
// ObsClient obsClient = new ObsClient(ak, sk, securityToken, endPoint);
try {
// 上传对象
PutObjectRequest request = new PutObjectRequest(bucketName, objectKey, localFile);
PutObjectResult result = obsClient.putObject(request);
// 判断上传返回状态码是否为200
if (result.getStatusCode() == 200) {
System.out.println("putObject successfully");
// 获取对象属性,确认对象存在
ObjectMetadata metadata = obsClient.getObjectMetadata(bucketName, objectKey);
System.out.println("getObjectMetadata successfully, object exists");
System.out.println("ContentType: " + metadata.getContentType());
} else {
System.out.println("putObject failed");
System.out.println("HTTP Code:" + result.getStatusCode());
}
} catch (ObsException e) {
System.out.println("putObject or getObjectMetadata failed");
// 请求失败,打印http状态码
System.out.println("HTTP Code:" + e.getResponseCode());
// 请求失败,打印服务端错误码
System.out.println("Error Code:" + e.getErrorCode());
// 请求失败,打印详细错误信息
System.out.println("Error Message:" + e.getErrorMessage());
// 请求失败,打印请求id
System.out.println("Request ID:" + e.getErrorRequestId());
System.out.println("Host ID:" + e.getErrorHostId());
e.printStackTrace();
} catch (Exception e) {
System.out.println("putObject or getObjectMetadata failed");
// 其他异常信息打印
e.printStackTrace();
}
}
} Python示例代码
向名为examplebucket的桶中上传名为exampleobject的对象,然后查看对象元数据:
import os
from obs import ObsClient
def main():
# 您可以通过环境变量获取访问密钥AK/SK,也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
# 您可以登录访问管理控制台获取访问密钥AK/SK
ak = os.getenv("ACCESS_KEY_ID")
sk = os.getenv("SECRET_ACCESS_KEY_ID")
# 【可选】如果使用临时AK/SK和SecurityToken访问OBS,同样建议您尽量避免使用硬编码,以降低信息泄露风险。
# 您可以通过环境变量获取访问密钥AK/SK/SecurityToken,也可以使用其他外部引入方式传入。
# securityToken = os.getenv("SECURITY_TOKEN")
# endpoint填写桶所在的endpoint, 此处以华北-北京四为例,其他地区请按实际情况填写。
server = "obs.cn-north-4.myhuaweicloud.com"
# 您可以通过环境变量获取endPoint,也可以使用其他外部引入方式传入。
# server = os.getenv("ENDPOINT")
bucketName = "examplebucket"
objectKey = "exampleobject"
localFile = "localfile.txt"
# 创建ObsClient实例
# 使用永久AK/SK初始化客户端
obsClient = ObsClient(access_key_id=ak, secret_access_key=sk, server=server)
# 使用临时AK/SK和SecurityToken初始化客户端
# obsClient = ObsClient(access_key_id=ak, secret_access_key=sk, security_token=securityToken, server=server)
try:
# 上传对象
resp = obsClient.putFile(bucketName, objectKey, localFile)
# 判断上传返回状态码是否为2xx
if resp.status >= 200 and resp.status < 300:
print("putFile successfully")
# 获取对象属性,确认对象存在
meta_resp = obsClient.getObjectMetadata(bucketName, objectKey)
if meta_resp.status >= 200 and meta_resp.status < 300:
print("getObjectMetadata successfully, object exists")
print("ContentType:", meta_resp.body.contentType)
else:
print("getObjectMetadata failed")
print("HTTP Code:", meta_resp.status)
else:
print("putFile failed")
print("HTTP Code:", resp.status)
print("Error Code:", resp.errorCode)
print("Error Message:", resp.errorMessage)
except Exception as e:
print("putFile or getObjectMetadata failed")
# 其他异常信息打印
print(e)
finally:
# 关闭ObsClient
obsClient.close()
if __name__ == '__main__':
main() 父主题: 桶和对象相关



