MongoDB如何通过change streams检测整数字段值的增减情况

前置配置 #

要实现数值增减判断，核心是需要获取字段变更前后的两个值做对比，需在开启变更流时配置fullDocumentBeforeChange参数获取变更前的完整文档：

• MongoDB 6.0及以上版本原生支持该配置，低版本需提前为集合开启变更历史留存，或自行在业务侧缓存字段最新值
• 开启变更流的示例代码（以Node.js驱动为例）：

// 配置开启变更前后文档获取
const changeStream = collection.watch([], { 
  fullDocument: 'updateLookup', 
  fullDocumentBeforeChange: 'required' 
});

核心判断逻辑 #

• 首先过滤非目标操作的变更事件，仅保留目标整数字段发生更新的事件
• 分别从fullDocumentBeforeChange中取字段旧值，从fullDocument或updateDescription.updatedFields中取字段新值
• 对比新旧值即可判断增减方向，差值可计算变化幅度
• 示例判断代码：

changeStream.on('change', (event) => {
  // 仅处理更新操作，可自行扩展新增、替换等操作的判断逻辑
  if (event.operationType !== 'update') return;
  // 替换为你需要判断的整数字段名
  const targetIntField = 'your_counter';
  // 过滤目标字段未发生变更的事件
  if (!event.updateDescription.updatedFields.hasOwnProperty(targetIntField)) return;

  const oldValue = event.fullDocumentBeforeChange[targetIntField];
  const newValue = event.fullDocument[targetIntField];

  if (newValue > oldValue) {
    console.log(`字段增长，变化量：${newValue - oldValue}`);
  } else if (newValue < oldValue) {
    console.log(`字段降低，变化量：${oldValue - newValue}`);
  }
});

注意事项 #

• 低版本MongoDB无法直接获取变更前文档时，可在业务侧用Redis等组件缓存字段最新值，每次收到变更事件后和缓存值对比，再更新缓存即可
• 仅需要判断增量方向不需要完整文档的场景下，可在变更流Pipeline中提前做字段投影，降低事件传输开销
• 高并发场景建议增加幂等判断，避免重复处理重复推送的变更事件

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