禁止覆盖同名文件
默认情况下,如果已经存在同名文件(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。
版权声明
本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。
评论