find_next_tweet_without_classification.py

import pymongo

mongoClient = pymongo.MongoClient(
    "mongodb://localhost:27017/", username="removed", password="removed")
mongoDatabase = mongoClient["twitter"]
mongoCollection = mongoDatabase["tweets"]

def fetch_next_tweet_without_classification():
    result = list(mongoCollection.aggregate([
        {
            '$project': {
                'id': True, 'text': True, 'classification': True, 'lang': True
            }
        },
        {
            '$match': {"classification": None}
        },
        {
            '$match': {"lang": {
                '$eq': 'en'
            }}
        },
        {
            '$limit': 1
        }
    ]))

    return result[0]