默认情况下,如果已经存在同名文件(Object)且对该文件有访问权限,则新添加的文件将覆盖原有的文件。本文介绍如何通过设置请求头x-oss-forbid-overwrite在简单上传、拷贝文件及分片上传等场景中禁止覆盖同名文件。

简单上传

以下代码用于简单上传时禁止覆盖同名文件:

# -*- coding: utf-8 -*-
import oss2

# 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
auth = oss2.Auth('<yourAccessKeyId>', '<yourAccessKeySecret>')
# Endpoint以杭州为例,其它Region请按实际情况填写。
bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<yourBucketName>')

# 上传文件。
# 指定PutObject操作时是否覆盖同名Object。
# 不指定x-oss-forbid-overwrite时,默认覆盖同名Object。
# 指定x-oss-forbid-overwrite为false时,表示允许覆盖同名Object。
# 指定x-oss-forbid-overwrite为true时,表示禁止覆盖同名Object,如果同名Object已存在程序将报错。
headers["x-oss-forbid-overwrite"] = "true"
result = bucket.put_object('<yourObjectName>', 'content of object', headers=headers)

# HTTP返回码。
print('http status: {0}'.format(result.status))
# 请求ID。请求ID是请求的唯一标识,强烈建议在程序日志中添加此参数。
print('request_id: {0}'.format(result.request_id))
# ETag是put_object方法返回值特有的属性。
print('ETag: {0}'.format(result.etag))
# HTTP响应头部。
print('date: {0}'.format(result.headers['date']))

简单上传的更多详情,请参见PutObject

拷贝文件

  • 拷贝小文件

    以下代码用于拷贝小文件时禁止覆盖同名文件:

    # -*- coding: utf-8 -*-
    import oss2
    
    # 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
    auth = oss2.Auth('<yourAccessKeyId>', '<yourAccessKeySecret>')
    # Endpoint以杭州为例,其它Region请按实际情况填写。
    bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<yourDestinationBucketName>')
    
    # 指定copy_object操作时是否覆盖同名Object。
    # 不指定x-oss-forbid-overwrite时,默认覆盖同名Object。
    # 指定x-oss-forbid-overwrite为false时,表示允许覆盖同名Object。
    # 指定x-oss-forbid-overwrite为true时,表示禁止覆盖同名Object,如果同名Object已存在程序将报错。
    headers = dict()
    headers["x-oss-forbid-overwrite"] = "true"
    bucket.copy_object('<yourSourceBucketName>', '<yourSourceObjectName>', '<yourDestinationObjectName>', headers=headers)
  • 拷贝大文件

    以下代码用于拷贝大文件(分片拷贝)时禁止覆盖同名文件:

    # -*- coding: utf-8 -*-
    import oss2
    from oss2.models import PartInfo
    from oss2 import determine_part_size
    
    # 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
    auth = oss2.Auth('<yourAccessKeyId>', '<yourAccessKeySecret>')
    # Endpoint以杭州为例,其它Region请按实际情况填写。
    bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<yourBucketName>')
    
    src_object = '<yourSourceObjectName>'
    dst_object = '<yourDestinationObjectName>'
    
    total_size = bucket.head_object(src_object).content_length
    part_size = determine_part_size(total_size, preferred_size=100 * 1024)
    
    # 初始化分片。
    # 指定拷贝文件操作时是否覆盖同名Object。
    # 不指定x-oss-forbid-overwrite时,默认覆盖同名Object。
    # 指定x-oss-forbid-overwrite为false时,表示允许覆盖同名Object。
    # 指定x-oss-forbid-overwrite为true时,表示禁止覆盖同名Object,如果同名Object已存在程序将报错。
    headers = dict()
    headers["x-oss-forbid-overwrite"] = "true"
    upload_id = bucket.init_multipart_upload(dst_object, headers=headers).upload_id
    parts = []
    
    # 逐个分片拷贝。
    part_number = 1
    offset = 0
    while offset < total_size:
        num_to_upload = min(part_size, total_size - offset)
        byte_range = (offset, offset + num_to_upload - 1)
    
        result = bucket.upload_part_copy(bucket.bucket_name, src_object, byte_range,dst_object, upload_id, part_number)
        parts.append(PartInfo(part_number, result.etag))
    
        offset += num_to_upload
        part_number += 1
    
    # 完成分片拷贝。
    # 指定拷贝文件操作时是否覆盖同名Object。
    # 不指定x-oss-forbid-overwrite时,默认覆盖同名Object。
    # 指定x-oss-forbid-overwrite为false时,表示允许覆盖同名Object。
    # 指定x-oss-forbid-overwrite为true时,表示禁止覆盖同名Object,如果同名Object已存在程序将报错。
    headers = dict()
    headers["x-oss-forbid-overwrite"] = "true"
    bucket.complete_multipart_upload(dst_object, upload_id, parts, headers=headers)                    

拷贝文件的更多详情,请参见CopyObject

分片上传

以下代码用于分片上传时禁止覆盖同名文件:

# -*- coding: utf-8 -*-
import os
from oss2 import SizedFileAdapter, determine_part_size
from oss2.models import PartInfo
import oss2

# 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
auth = oss2.Auth('<yourAccessKeyId>', '<yourAccessKeySecret>')
# Endpoint以杭州为例,其它Region请按实际情况填写。
bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<yourBucketName>')

key = '<yourObjectName>'
filename = '<yourLocalFile>'

total_size = os.path.getsize(filename)
# determine_part_size方法用来确定分片大小。
part_size = determine_part_size(total_size, preferred_size=100 * 1024)

# 初始化分片。
# 指定分片上传操作时是否覆盖同名Object。
# 不指定x-oss-forbid-overwrite时,默认覆盖同名Object。
# 指定x-oss-forbid-overwrite为false时,表示允许覆盖同名Object。
# 指定x-oss-forbid-overwrite为true时,表示禁止覆盖同名Object,如果同名Object已存在程序将报错。
headers["x-oss-forbid-overwrite"] = "true"
upload_id = bucket.init_multipart_upload(key, headers=headers).upload_id
parts = []

# 逐个上传分片。
with open(filename, 'rb') as fileobj:
    part_number = 1
    offset = 0
    while offset < total_size:
        num_to_upload = min(part_size, total_size - offset)
        # SizedFileAdapter(fileobj, size)方法会生成一个新的文件对象,重新计算起始追加位置。
        result = bucket.upload_part(key, upload_id, part_number,
                                    SizedFileAdapter(fileobj, num_to_upload))
        parts.append(PartInfo(part_number, result.etag))

        offset += num_to_upload
        part_number += 1

# 完成分片上传。
# 指定分片上传操作时是否覆盖同名Object。
# 不指定x-oss-forbid-overwrite时,默认覆盖同名Object。
# 指定x-oss-forbid-overwrite为false时,表示允许覆盖同名Object。
# 指定x-oss-forbid-overwrite为true时,表示禁止覆盖同名Object,如果同名Object已存在程序将报错。
headers["x-oss-forbid-overwrite"] = "true"
bucket.complete_multipart_upload(key, upload_id, parts, headers=headers)

# 验证分片上传。
with open(filename, 'rb') as fileobj:
    assert bucket.get_object(key).read() == fileobj.read()

分片上传的更多详情,请参见InitiateMultipartUpload以及CompleteMultipartUpload