| 1234567891011121314151617181920212223242526 |
- def check_object_exist(self, upload_id_list, clean_flag):
- """
- 检查源文件是否存在于对象存储中
- :param clean_flag 是否清理了未完成的分片上传
- :param upload_id_list: 未完成的 upload id
- :return:
- """
- object_size = self.get_object_info()
- if object_size == -1:
- if upload_id_list and (not clean_flag):
- # 查看对象是否存在于未完成的分片上传中，如果不存在，全新上传。如果在继续完成分片上传
- for upload_info in upload_id_list:
- if MULTIPART_UPLOAD_FILE_NAME in upload_info["Key"]:
- # 表示存在该对象未完成上传的分片信息，返回该分片信息
- print ("存在对象 {} 分片上传信息".format(MULTIPART_UPLOAD_FILE_NAME))
- return upload_info["UploadId"]
- else:
- # 表示这个对象不存在，也不存在分片信息。
- print ("不存在对象 {} 分片上传信息".format(MULTIPART_UPLOAD_FILE_NAME))
- return self.init_multipart_upload()
- elif object_size == MULTIPART_UPLOAD_FILE_SIZE:
- # 表示对象已经存在，不用重复上传
- print ("文件 {} 已存在，请检查后再上传！".format(MULTIPART_UPLOAD_FILE))
- sys.exit(-1)
|
