如何通过MongoDB Change Streams检测数据库变更的来源？

默认情况下MongoDB变更流返回的事件不会直接包含变更发起方的标识信息，要区分内部应用操作和外部工具（如MongoDB Compass）的操作，可以通过以下几种方式实现：

一、自定义客户端标识（最推荐） #

在应用的所有数据库写操作中，主动添加自定义的客户端元数据，比如通过会话注释实现：

1. 应用操作时添加会话注释 #

// 应用发起写操作时，创建带专属注释的会话
const session = client.startSession({ comment: "internal-app-v1.0" });

try {
  await collection.insertOne(
    { /* 业务文档内容 */ },
    { session }
  );
} finally {
  await session.endSession();
}

2. 在变更流中提取注释信息 #

修改变更流监听逻辑，开启扩展事件后读取会话注释：

let changeStream = collection.watch([], {
  showExpandedEvents: true // 开启扩展事件才能获取会话注释
});

changeStream.on("change", (event) => {
  const clientComment = event.operationDescription?.session?.comment;
  if (clientComment === "internal-app-v1.0") {
    console.log("变更来自内部应用", event);
  } else {
    console.log("变更来自外部工具/未知来源", event);
  }
});

二、利用连接元数据（有限场景可用） #

MongoDB 5.0及以上版本，变更流可以返回发起变更的客户端连接信息（如IP、端口），但需要开启对应选项且用户有足够权限：

let changeStream = collection.watch([], {
  showExpandedEvents: true,
  includeTransactionDetails: true
});

changeStream.on("change", (event) => {
  const clientInfo = event.operationDescription?.client;
  if (clientInfo) {
    console.log("客户端IP:", clientInfo.address);
    // 若应用服务器有固定IP段，可通过IP范围判断是否为内部应用
    if (clientInfo.address.startsWith("192.168.1.")) {
      console.log("变更来自内部应用");
    }
  }
});

这种方法局限性：外部工具如果和应用在同一IP段则无法区分，且依赖特定MongoDB版本。

三、文档字段标记（简单直接） #

如果允许修改文档结构，可以在写操作时给文档添加modifiedBy字段：

// 应用内的更新操作
await collection.updateOne(
  { _id: targetId },
  { 
    $set: { /* 更新内容 */ },
    $setOnInsert: { modifiedBy: "internal-app" }
  }
);

然后在变更流的updateDescription.updatedFields或fullDocument中读取该字段，判断发起方。

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