Skip to content

S3 batch delete #78

Open
Open
@kislyuk

Description

@kislyuk
bucket = s3.Bucket(...)
def delete_objects(objs):
    print(len(objs), objs[0])
    return bucket.delete_objects(Delete={"Objects": [{"Key": obj.key} for obj in objs]})
with ThreadPoolExecutor(max_workers=4) as executor:
    for res in executor.map(delete_objects, batched(bucket.objects.all(), 1000)):
        print(json.dumps(res))

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions