from pymongo import MongoClient uri = "mongodb://username:password@server:27017/collection?readPreference=nearest" client = MongoClient(uri, readPreference='nearest') db = client.IntellogoRatings pipeline = [ { "$limit": 30 }] list(db.ratings.aggregate(pipeline)) print("done")