MongoDBInsert.py

def writeTweets(tweets):
    '''
    See Extraction_Exapmple.py to see how to parse tweets into newTweetRecords
    '''
    try:
        result = collection.insert_many(newTweetRecords, ordered=False)
        i += len(newTweetRecords)
    except pymongo.errors.BulkWriteError as e:
        panic = list(filter(lambda x: x['code'] != 11000, e.details['writeErrors']))
        if len(panic) > 0:
            print(e)