def get_upload_collection(): s = get_connection_string() logger.info('Opening connection to MongoDB...') client = pymongo.MongoClient(s) db = client[mongo_db] collection = db[mongo_collection] return collection
