filename = args.upload_file

key = os.path.split(filename)[1]

for param in (access_key_id, access_key_secret, bucket_name, endpoint):

assert '<' not in param, '请设置参数：' + param

bucket = oss2.Bucket(oss2.Auth(access_key_id, access_key_secret), endpoint, bucket_name)

total_size = os.path.getsize(filename)

part_size = determine_part_size(total_size, preferred_size=100000 * 1024)

# 初始化分片

print('OSS initializing:')

encode_md5 = calculate_file_md5(filename)

print('%s s md5 is %s' % (filename, encode_md5))

upload_id = bucket.init_multipart_upload(key).upload_id

parts = []

# 逐个上传分片

print('Seperate the file batch and uploading:')

with open(filename, 'rb') as fileobj:

part_number = 1

offset = 0

while offset < total_size:

num_to_upload = min(part_size, total_size - offset)

result = bucket.upload_part(key, upload_id, part_number,

SizedFileAdapter(fileobj, num_to_upload), progress_callback=percentage)

parts.append(PartInfo(part_number, result.etag))

offset += num_to_upload

part_number += 1

# 完成分片上传

print('Complete the uploading task:')

result = bucket.complete_multipart_upload(key, upload_id, parts)

print('upload results: %i' % result)

if total_bytes:

rate = int(100 * (float(consumed_bytes) / float(total_bytes)))

sys.stdout.write('\r{0}% '.format(rate))

"""计算文件的MD5

with open(file_name, 'rb') as f:

md5 = hashlib.md5()

while True:

data = f.read(block_size)

if not data:

break

md5.update(data)

parser = argparse.ArgumentParser()

parser.add_argument('upload_file', type=str,

help='file for uploading to Aliyun OSS.')