def run(self):
while not self.job_queue.empty():
try:
key = self.job_queue.get(True, 1)
except Empty:
return
try:
self.s3.head_object(Bucket=self.source, Key=key)
logger.info('Key: ' + key + ' is present in source bucket, nothing to do.')
except ClientError as e:
if int(e.response['Error']['Code']) == 404: # The key was not found.
logger.info('Key: ' + key + ' is not present in source bucket. Deleting orphaned key.')
self.s3.delete_object(Bucket=self.destination, Key=key)
else:
raise e
# Functions
delete_orphaned_keys.py 文件源码
python
阅读 18
收藏 0
点赞 0
评论 0
评论列表
文章目录