pymongo

mongo_access.py

import pymongo
import sys
import traceback
from datetime import datetime
import time

MONGO_HOST = 'XXX.XXX.XXX.XXX'
network_timeout = int(sys.argv[1])
repeat = int(sys.argv[2])
sleep = float(sys.argv[3]) if len(sys.argv) > 3 else 1

conn = pymongo.Connection(MONGO_HOST,
                          network_timeout=network_timeout,
                          max_pool_size=2)

for i in range(repeat):
    print str(datetime.now())
    try:
        coll = conn.test.category
        cur = coll.find().sort('CD')
        if cur.count():
            categories = [r['Name'] for r in cur]
        print ','.join(categories)
    except:
        traceback.print_exc()
    time.sleep(sleep)