MongoDBExecute.py

def main():
    client = MongoClient('mongodb://mongodb:27017', username='<username>', password='<password>', authSource='admin')
    tweetCol = client['twitter']['tweets']
    todoCol = client['twitter']['queriesTodo']
    currentQuery = todoCol.find_one_and_delete({})
    while currentQuery != None:
        executeQuery(currentQuery["qWords"], currentQuery["since"], currentQuery["until"], tweetCol)
        currentQuery = todoCol.find_one_and_delete({})