gistfile1.txt

src = pymongo.Connection()
dst = pymongo.Connection(<mongos addr>)

srcdb = src[db]
dstdb = dst[db]

srccoll = srcdb[collection]
dstcoll = dstdb[collection]

logging.basicConfig(format='%(asctime)s %(message)s', level=logging.INFO)

i = 0

for i, d in enumerate(srccoll.find()):
        if i % 10000 == 0:
                logging.info('did %d', i)
        dstcoll.save(d)

logging.info('did a total of %d', i)