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