@@ -1241,7 +1241,7 @@ def upload_file(self, Bucket, Key, LocalFilePath, PartSize=10, MAXThread=5, **kw
1241
1241
:param PartSize(int): 分块的大小设置.
1242
1242
:param MAXThread(int): 并发上传的最大线程数.
1243
1243
:param kwargs(dict): 设置请求headers.
1244
- :return: None .
1244
+ :return(dict): 成功上传文件的元信息 .
1245
1245
"""
1246
1246
file_size = os .path .getsize (LocalFilePath )
1247
1247
if file_size <= 1024 * 1024 * 100 :
@@ -1416,10 +1416,11 @@ def upload_file_from_buffer(self, Bucket, Key, Body, MaxBufferSize=100, PartSize
1416
1416
:param Bucket(string): 存储桶名称.
1417
1417
:param key(string): 分块上传路径名.
1418
1418
:param Body(fp): 文件流,必须实现了read方法.
1419
- :param PartSize(int): 分块的大小设置.
1419
+ :param MaxBufferSize(int): 缓存文件的大小,单位为MB,MaxBufferSize/PartSize决定线程池中最大等待调度的任务数量
1420
+ :param PartSize(int): 分块的大小设置,单位为MB
1420
1421
:param MAXThread(int): 并发上传的最大线程数.
1421
1422
:param kwargs(dict): 设置请求headers.
1422
- :return: None .
1423
+ :return(dict): 成功上传的文件的结果 .
1423
1424
"""
1424
1425
if not hasattr (Body , 'read' ):
1425
1426
raise CosClientError ("Body must has attr read" )
@@ -1454,7 +1455,6 @@ def upload_file_from_buffer(self, Bucket, Key, Body, MaxBufferSize=100, PartSize
1454
1455
# 完成分片上传
1455
1456
try :
1456
1457
rt = self .complete_multipart_upload (Bucket = Bucket , Key = Key , UploadId = uploadid , MultipartUpload = {'Part' : lst })
1457
- print rt
1458
1458
except Exception as e :
1459
1459
abort_response = self .abort_multipart_upload (Bucket = Bucket , Key = Key , UploadId = uploadid )
1460
1460
raise e
0 commit comments