MongoDB Change Stream数组截断字段解析及触发方法咨询

一、truncatedArrays的定义 #

truncatedArrays是MongoDB变更流（Change Stream）更新事件里updateDescription结构的一部分，专门用于记录通过管道式更新操作对数组执行的截断行为——也就是将数组的长度缩短至原长度以内的操作，且这类操作必须通过官方指定的几个管道阶段完成。

官方文档说明：

该数组记录通过基于管道的更新（使用以下一个或多个阶段）执行的数组截断操作：

• $addFields
• $set
• $replaceRoot
• $replaceWith

二、触发核心条件 #

要触发包含truncatedArrays的更新事件，必须同时满足：

1. 使用管道式更新：即updateOne/updateMany的第二个参数是数组形式的聚合管道，而非普通的键值对更新文档；
2. 管道中包含指定阶段：必须用到$addFields/$set/$replaceRoot/$replaceWith中的至少一个；
3. 执行数组截断操作：通过上述管道阶段将目标数组替换为一个长度更短的数组。

三、具体触发示例 #

1. 准备测试数据 #

先插入一条带数组字段的文档：

db.test.insertOne({
  _id: 1,
  scores: [85, 90, 92, 78, 88] // 原数组长度为5
})

2. 用$set管道阶段截断数组 #

执行管道式更新，通过$slice操作截取数组前3个元素，实现截断：

db.test.updateOne(
  { _id: 1 },
  [
    { $set: { scores: { $slice: ["$scores", 3] } } }
  ]
)

3. 查看变更流事件 #

通过变更流监听该集合的更新事件：

const changeStream = db.test.watch();
while (await changeStream.hasNext()) {
  const change = await changeStream.next();
  console.log(JSON.stringify(change.updateDescription, null, 2));
}

此时输出的updateDescription会包含truncatedArrays字段，内容如下：

{
  "updatedFields": {
    "scores": [85, 90, 92]
  },
  "truncatedArrays": [
    {
      "field": "scores",
      "newSize": 3,
      "oldSize": 5
    }
  ],
  "removedFields": []
}

4. 用$replaceWith管道阶段截断数组 #

再执行另一个管道式更新，通过$replaceWith直接替换文档，只保留数组前2个元素：

db.test.updateOne(
  { _id: 1 },
  [
    { $replaceWith: { _id: "$_id", scores: ["$scores.0", "$scores.1"] } }
  ]
)

此时变更流输出的truncatedArrays会记录新旧数组长度的变化：

{
  "updatedFields": {
    "scores": [85, 90]
  },
  "truncatedArrays": [
    {
      "field": "scores",
      "newSize": 2,
      "oldSize": 3
    }
  ],
  "removedFields": []
}

四、关键注意事项 #

• 普通非管道式的数组替换（比如db.test.updateOne({_id:1}, {$set: {scores: [85,90]}})）不会触发truncatedArrays，必须使用管道形式的更新；
• 使用$pop、$pull这类专门的数组操作符执行的缩短数组操作，只会被记录在updatedFields中，不会进入truncatedArrays字段。

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