如何在MongoDB变更流中监听指定字段变更及插入操作？

要同时捕获插入操作和name/message字段的更新操作，需要调整Change Stream的过滤条件，同时匹配两种事件类型：

核心修改点 #

在$match的$or数组中新增对operationType: 'insert'的匹配，并且对原有的更新条件补充operationType: 'update'的限定（避免无意义的字段检查）：

const mongoose = require('mongoose');
const myModel = require('../models/myModel');

const getConnection = async (callback, io) => {
try {
    await mongoose.connect(process.env.DATABASE, {});
    const filter = [{
        $match: {
            $or: [
                // 匹配插入操作
                { operationType: 'insert' },
                // 匹配更新操作，且更新了name或message字段
                {
                    operationType: 'update',
                    $or: [
                        { "updateDescription.updatedFields.name": { $exists: true } },
                        { "updateDescription.updatedFields.message": { $exists: true } }
                    ]
                }
            ]
        }
    }];

    const options = { fullDocument: 'updateLookup', fullDocumentBeforeChange: 'whenAvailable' };
    // Mongoose模型的collection属性直接关联对应集合，无需传集合名
    myModel.collection.watch(filter, options).on('change', async (event) => {
        console.log('event:', event);
        // 可根据operationType区分处理逻辑
        if (event.operationType === 'insert') {
            // 处理插入逻辑
        } else if (event.operationType === 'update') {
            // 处理更新逻辑
        }
    });
 } catch (error) {
   console.log('error', error);
 }
}

关键说明 #

• operationType是Change Stream事件的核心标识，insert对应插入操作，update对应更新操作
• 原代码中myModel.collection('myCollection')是错误用法，Mongoose模型定义时已关联集合，直接调用myModel.collection即可
• fullDocument: 'updateLookup'可以在更新事件中获取完整的文档内容，方便后续业务处理

内容的提问来源于stack exchange，提问作者Dev M