Change Stream for MongoDB using Windows 10, Docker, MongoDB and pymongo snippet

change_stream_example.py

# Change Stream Example
# using PYMONGO v3.9.0
import sys
import pprint
from pymongo import MongoClient

# Create a Client to our Replica Set
cl = MongoClient(host='localhost', port=37017, replicaSet='rs0')

# Database: `team` # Collection: `players`
db = cl['team']

# using `watch()` for change streams in pymongo
try:
    with db['players'].watch() as change_stream:
        for change in change_stream:
            pprint.pprint(change) ## should pretty print the newly inserted doc
except KeyboardInterrupt:
    cl.close()
    sys.exit()
except Exception as e:
    print(e)