PUT /exampleobject HTTP/1.1Host: examplebucket-1250000000.cos.ap-beijing.myqcloud.comDate: Fri, 21 Jun 2019 09:24:28 GMTContent-Type: image/jpegContent-Length: 13Content-MD5: ti4QvKtVqIJAvZxDbP/c+Q==Authorization: q-sign-algorithm=sha1&q-ak=AKID8A0fBVtYFrNm02oY1g1JQQF0c3JO****&q-sign-time=1561109068;1561116268&q-key-time=1561109068;1561116268&q-header-list=content-length;content-md5;content-type;date;host&q-url-param-list=&q-signature=998bfc8836fc205d09e455c14e3d7e623bd2****x-cos-meta-md5: b62e10bcab55a88240bd9c436cffdcf9Connection: close[Object Content]
POST /exampleobject?uploads HTTP/1.1Host: examplebucket-1250000000.cos.ap-beijing.myqcloud.comDate: Fri, 21 Jun 2019 09:45:12 GMTAuthorization: q-sign-algorithm=sha1&q-ak=AKID8A0fBVtYFrNm02oY1g1JQQF0c3JO****&q-sign-time=1561109068;1561116268&q-key-time=1561109068;1561116268&q-header-list=content-length;content-md5;content-type;date;host&q-url-param-list=&q-signature=998bfc8836fc205d09e455c14e3d7e623bd2****x-cos-meta-md5: b62e10bcab55a88240bd9c436cffdcf9
HTTP/1.1 200 OKContent-Type: application/octet-streamContent-Length: 13Connection: closeAccept-Ranges: bytesCache-Control: max-age=86400Content-Disposition: attachment; filename=example.jpgDate: Thu, 04 Jul 2019 11:33:00 GMTETag: "b62e10bcab55a88240bd9c436cffdcf9"Last-Modified: Thu, 04 Jul 2019 11:32:55 GMTServer: tencent-cosx-cos-request-id: NWQxZGUzZWNfNjI4NWQ2NF9lMWYyXzk1NjFj****x-cos-meta-md5: b62e10bcab55a88240bd9c436cffdcf9[Object Content]
# -*- coding=utf-8from qcloud_cos import CosConfigfrom qcloud_cos import CosS3Clientfrom qcloud_cos import CosServiceErrorfrom qcloud_cos import CosClientErrorimport sysimport osimport loggingimport hashliblogging.basicConfig(level=logging.INFO, stream=sys.stdout)# 设置用户属性, 包括 SecretId, SecretKey, Region# APPID 已在配置中移除,请在参数 Bucket 中带上 APPID。Bucket 由 BucketName-APPID 组成。secret_id = os.environ['COS_SECRET_ID'] # 用户的 SecretId,建议使用子账号密钥,授权遵循最小权限指引,降低使用风险。子账号密钥获取可参考 https://www.tencentcloud.com/document/product/598/37140?from_cn_redirect=1secret_key = os.environ['COS_SECRET_KEY'] # 用户的 SecretKey,建议使用子账号密钥,授权遵循最小权限指引,降低使用风险。子账号密钥获取可参考 https://www.tencentcloud.com/document/product/598/37140?from_cn_redirect=1region = 'ap-beijing' # 替换为您的 Region, 这里以北京为例token = None # 临时密钥的 Token,临时密钥生成和使用指引参见 https://www.tencentcloud.com/document/product/436/14048?from_cn_redirect=1config = CosConfig(Region=region, SecretId=secret_id, SecretKey=secret_key, Token=token) # 获取配置对象client = CosS3Client(config)
object_body = 'hello cos'#得到对象的 md5 校验值md5 = hashlib.md5()md5.update(object_body)md5_str = md5.hexdigest()
#简单上传对象,并打开 MD5 校验response = client.put_object(Bucket='examplebucket-1250000000', #替换为您的 Bucket 名称,examplebucket 是一个举例的存储桶,1250000000 为举例的 APPID。Body='hello cos', #上传的对象内容Key='example-object-1', #替换为您上传的对象 Key 值EnableMD5=True, #开启上传的 MD5 校验Metadata={ #设置自定义参数,将对象的 MD5 校验值作为参数值存入 COS 服务器'x-cos-meta-md5' : md5_str})print 'ETag: ' + response['ETag'] # Object 的 Etag 值
#下载对象response = client.get_object(Bucket='examplebucket-1250000000', #替换为您的 Bucket 名称,examplebucket 是一个举例的存储桶,1250000000 为举例的 APPID。Key='example-object-1' #下载对象的 Key 值)fp = response['Body'].get_raw_stream()download_object = fp.read() #得到对象内容print "get object body: " + download_objectprint 'ETag: ' + response['ETag']print 'x-cos-meta-md5: ' + response['x-cos-meta-md5'] #得到用户自定义参数 x-cos-meta-md5
#计算下载对象的 MD5 校验值md5 = hashlib.md5()md5.update(download_object)md5_str = md5.hexdigest()print 'download object md5: ' + md5_str#通过下载对象的 MD5 校验值与上传对象的 MD5 校验值比较,从而验证对象的一致性if md5_str == response['x-cos-meta-md5']:print 'MD5 check OK'else:print 'MD5 check FAIL'
OBJECT_PART_SIZE = 1024 * 1024 #模拟每个分块的大小OBJECT_TOTAL_SIZE = OBJECT_PART_SIZE * 1 + 123 #对象的总大小object_body = '1' * OBJECT_TOTAL_SIZE #对象内容#计算整个对象内容的 MD5 校验值md5 = hashlib.md5()md5.update(object_body)md5_str = md5.hexdigest()
#初始化分块上传response = client.create_multipart_upload(Bucket='examplebucket-1250000000', #替换为您的 Bucket 名称,examplebucket 是一个举例的存储桶,1250000000 为举例的 APPID。Key='exampleobject-2', #替换为您上传的对象 Key 值StorageClass='STANDARD', #对象的存储级别Metadata={'x-cos-meta-md5' : md5_str #设置自定义参数,设置为 MD5 校验值})#获取分块上传的 UploadIdupload_id = response['UploadId']
#分块上传对象,每个分块大小为 OBJECT_PART_SIZE,最后一个分块可能不足 OBJECT_PART_SIZEpart_list = list()position = 0left_size = OBJECT_TOTAL_SIZEpart_number = 0while left_size > 0:part_number += 1if left_size >= OBJECT_PART_SIZE:body = object_body[position:position+OBJECT_PART_SIZE]else:body = object_body[position:]position += OBJECT_PART_SIZEleft_size -= OBJECT_PART_SIZE#上传分块response = client.upload_part(Bucket='examplebucket-1250000000', #替换为您的 Bucket 名称,examplebucket 是一个举例的存储桶,1250000000 为举例的 APPID。Key='exampleobject-2', #对象的 Key 值Body=body,PartNumber=part_number,UploadId=upload_id,EnableMD5=True #打开分块校验,COS 服务器会对每个分块进行 MD5 校验。)etag = response['ETag'] #ETag 表示每个分块的 MD5 值part_list.append({'ETag' : etag, 'PartNumber' : part_number})print etag + ', ' + str(part_number)
#完成分块上传response = client.complete_multipart_upload(Bucket='examplebucket-1250000000', #替换为您的 Bucket 名称,examplebucket 是一个举例的存储桶,1250000000 为举例的APPID。Key='exampleobject-2', #对象的 Key 值UploadId=upload_id,MultipartUpload={ #要求每个分块的 ETag 和 PartNumber 一一对应'Part' : part_list},)#ETag 表示合并后对象的唯一标签值,该值不是对象内容的 MD5 校验值,仅用于检查对象唯一性。print "ETag: " + response['ETag']print "Location: " + response['Location'] #URL地址print "Key: " + response['Key']
# 下载对象response = client.get_object(Bucket='examplebucket-1250000000', #替换为您的 Bucket 名称,examplebucket 是一个举例的存储桶,1250000000 为举例的 APPID。Key='exampleobject-2' #对象的 Key 值)print 'ETag: ' + response['ETag'] #对象的 ETag 不是对象内容的 MD5 校验值print 'x-cos-meta-md5: ' + response['x-cos-meta-md5'] #得到用户自定义参数 x-cos-meta-md5
#计算下载对象的 MD5 校验值fp = response['Body'].get_raw_stream()DEFAULT_CHUNK_SIZE = 1024*1024md5 = hashlib.md5()chunk = fp.read(DEFAULT_CHUNK_SIZE)while chunk:md5.update(chunk)chunk = fp.read(DEFAULT_CHUNK_SIZE)md5_str = md5.hexdigest()print 'download object md5: ' + md5_str#通过下载对象的 MD5 校验值与上传对象的 MD5 校验值比较,从而验证对象的一致性if md5_str == response['x-cos-meta-md5']:print 'MD5 check OK'else:print 'MD5 check FAIL'
文档反馈