Skeleton MapReduce in Python

skelmr.py

from multiprocessing import Pool

def mapFunction(value):
  # work on values
  return a_tuple

def partition(tuples):
  # marshalll tuples into a dictionary of lists of tuples
  return mapping
  
def reduceFunction(mapping):  
  # work on the mapping
  return results
  
if __name__ == '__main__':    
  pool = Pool(processes=N)  
  tuples = pool.map(mapFunction, your_iterable_data)
  mapping = partition(tuples)
  results = pool.map(reduceFunction, mapping.items())    
  # do something wit the results