GnnForPrivacyScan/data/purposeSplit/Share/multipart_upload_4.py

def get_upload_id_list(self):
    """
    获取桶内是否存在未完成的multipart

    :return: 未完成 upload id list
    """
    
    upload_id_list = []
    res = self.s3_client.list_multipart_uploads(Bucket=DESTINATION_BUCKET)
    try:
        # 如果桶内不存在未完成的分片上传，response里就不存在 Uploads 字段
        for upload_info in res["Uploads"]:
            upload_id_list.append(
                {
                    "Key": upload_info["Key"],
                    "Initiated": upload_info["Initiated"],
                    "UploadId": upload_info["UploadId"]
                }
            )
            print ("存在未完成分片  对象名 : {}, 初始化上传时间 : {}".format(upload_info["Key"], upload_info["Initiated"]))
    except Exception as e:
        # TODO 后面需要确定是哪种异常类型
        print ("桶 {} 没有未完成的分片上传".format(DESTINATION_BUCKET))
    return upload_id_list