clean_bucket.py

#!/usr/bin/env python

import sys
import Queue
from threading import Thread

import boto
import boto.s3

s3 = boto.s3.connect_to_region('ap-northeast-1')
bucket_name = sys.argv[1]
bucket = s3.get_bucket(bucket_name)
objects = bucket.list()

num_worker_threads = 50

q = Queue.Queue()
for object in objects:
    q.put(object)
    loop += 1

def worker():
    while True:
        item = q.get()
        print bucket.delete_key(item.key)
        q.task_done()

for i in range(num_worker_threads):
    t = Thread(target=worker)
    t.setDaemon(True)
    t.start()

q.join()