Change stream pipeline on nested fields

[steevej (Steeve Juneau)]

Read the following thread. At first sight it looks like it is the same issue.

'match' not operating as expected within watch(pipeline) functionality on nested fields

Hi, I’m trying to set up a listener to a Mongo DB collection using the inbuilt change streams functionality. I’m coming into issues when I set up my watch on the collection when filtering for nested fields. I’m using PyMongo and my Mongo DB is hosted on Atlas. Here is my code… import pymongo client = pymongo.MongoClient(connection_uri) pipeline = [ { '$match': { '$or': [ {'updateDescription.updatedFields.base_name': {'$exists': True}}, …