def query_log(): connection = Connection('localhost', 27017) db = connection.mydb collection = db.logdata for doc in collection.find(): print(doc) connection.close()