node.js - mongodb changestream“管道”不起作用nodejs

Question

我有以下更改流，但是一旦我使用 mongo compass 更新，就不会记录它的功能更改。

var pipeline = [
  { $match: { _id: ObjectId(id) } }
];
try {
  const collection = client.db("mydb").collection("shop");
  const changeStream = collection.watch(pipeline);
  changeStream.on('change', (next) => {
    //console.log(next);
    console.log('changed')
  }, err => {
    console.log(err);
  });
} catch (err) {
  console.log(err)
}

Answer 1

问题是您通常不更新集合中文档的 _id 吗？如果由于某种原因，您正在更新 _id，那么问题可能在于您如何引用 $match。这对我有用：

const pipeline01 = [
  { $match: { 'updateDescription.updatedFields.fieldIamInterestedIn': { $ne: undefined } } },
  { $project: { 'fullDocument._id': 1, 'fullDocument.anotherFieldIamInterestedIn': 1 } },
];
theCollectionIamWatching.watch(pipeline01, { fullDocument: 'updateLookup' }).on('change', async (data) => {
// do the thing I want to do using data.fullDocument
});