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)