gistfile1.py

import db
from multiprocessing import Pool

def process_pollution(wb):
	pass

if __name__ == '__main__':
	items = db.waterbodies.find()
	p = Pool(16)
	p.map(process_pollution, items)