Thông báo MongoDB bằng Python

MongoDB 3.6 hỗ trợ $changeStream tính năng xem các thay đổi trên một bộ sưu tập.

Ví dụ sử dụng PyMongo tương thích với MongoDB 3.6:

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

ChangeStream được trả về sẽ tự động tiếp tục khi nó gặp lỗi có thể khôi phục được trong quá trình lặp lại. Quá trình lý lịch là minh bạch đối với ứng dụng và đảm bảo không có tài liệu luồng thay đổi nào bị mất.

Một ví dụ khác để xem tất cả các lần chèn đang diễn ra trên một bộ sưu tập bằng cách sử dụng 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('...')