delete_orphaned_keys.py 文件源码

python
阅读 18 收藏 0 点赞 0 评论 0

项目:sync-buckets-state-machine 作者: awslabs 项目源码 文件源码
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
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号