पायथन में MongoDB अधिसूचना

MongoDB 3.6 $changeStream . का समर्थन करता है संग्रह में परिवर्तन देखने की सुविधा।

उदाहरण के लिए MongoDB 3.6 के साथ संगत PyMongo का उपयोग करना:

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

चेंजस्ट्रीम लौटाया गया स्वचालित रूप से फिर से शुरू हो जाता है जब इसे पुनरावृत्ति के दौरान संभावित रूप से पुनर्प्राप्त करने योग्य त्रुटि का सामना करना पड़ता है। फिर से शुरू करने की प्रक्रिया आवेदन के लिए पारदर्शी है और यह सुनिश्चित करती है कि कोई भी परिवर्तन स्ट्रीम दस्तावेज़ खो न जाए।

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('...')