Pemberitahuan MongoDB dengan Python

MongoDB 3.6 mendukung $changeStream fitur untuk melihat perubahan pada koleksi.

Misalnya menggunakan PyMongo yang kompatibel dengan MongoDB 3.6:

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

ChangeStream yang dikembalikan secara otomatis dilanjutkan ketika menemukan kesalahan yang berpotensi dapat dipulihkan selama iterasi. Proses resume transparan untuk aplikasi dan memastikan tidak ada dokumen aliran perubahan yang hilang.

Contoh lain untuk melihat semua sisipan yang terjadi pada koleksi menggunakan 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('...')