MongoDB-meddelande i Python

MongoDB 3.6 stöder $changeStream funktion för att se ändringar på en samling.

Till exempel med PyMongo kompatibel med MongoDB 3.6:

   for change in db.collection.watch():
       print(change)

Den returnerade ChangeStream återupptas automatiskt när den stöter på ett potentiellt återställbart fel under iteration. Återuppta processen är transparent för applikationen och säkerställer att inga ändringsflödesdokument går förlorade.

Ett annat exempel för att titta på alla inlägg som sker på en samling med PyMongo :

    try:
        for insert_change in db.collection.watch(
                [{'$match': {'operationType': 'insert'}}]):
            print(insert_change)

    except pymongo.errors.PyMongoError:

        # We know it's unrecoverable:
        log.error('...')