Purges all keys from riak via python.

wipe_riak.py

import riak
import multiprocessing


keys = []
c = riak.RiakClient()
for b in c.get_buckets():
  k = [(b.name, key) for key in b.get_keys()]
  keys.extend(k)

print len(keys)

def f(args):
  c = riak.RiakClient()
  b, key = args
  print "Deleting", key, b, multiprocessing.current_process()
  c.bucket(b).delete(key)

pool = multiprocessing.Pool()
pool.map_async(f, keys, 100)
pool.close()
pool.join()