如何使用Mongoose控制Change Stream输出，仅跟踪指定ID文档？

当然可以实现，MongoDB的Change Streams支持通过聚合管道的$match阶段过滤事件，Mongoose的watch()方法直接接受聚合管道参数。核心思路是匹配变更事件里的documentKey._id字段（这个字段存储了变更文档的主键，所有变更类型事件都会包含它）。

针对数字类型ID的场景（你提到的id为1、2） #

直接用$in匹配目标ID数组即可：

const pipeline = [
  {
    $match: {
      'documentKey._id': { $in: [1, 2] }
    }
  }
];

Person.watch(pipeline).on('change', data => console.log(data));

针对MongoDB默认ObjectId类型ID的场景 #

如果你的文档主键是MongoDB默认的ObjectId，需要先将数字ID转换为ObjectId实例：

const mongoose = require('mongoose');
// 替换为你实际需要跟踪的ID对应的ObjectId字符串
const targetIds = [
  mongoose.Types.ObjectId('替换为id=1的ObjectId'),
  mongoose.Types.ObjectId('替换为id=2的ObjectId')
];

const pipeline = [
  {
    $match: {
      'documentKey._id': { $in: targetIds }
    }
  }
];

Person.watch(pipeline).on('change', data => console.log(data));

注意事项 #

• Change Streams要求MongoDB版本3.6及以上，且集合所在的数据库必须是副本集或分片集群架构（单节点实例不支持）。
• 不管是插入、更新、删除还是替换文档的事件，documentKey字段都会存在，所以用它做过滤是最可靠的方式。

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