MongoDB的聚合管道功能一直在进化，从早期的简单过滤统计，到后来引入的窗口函数能力，越来越多的场景可以完全在数据库层完成。其中$shift是一个比较特殊的存在：它允许你在处理某一条文档时，按照指定的偏移量去访问同一集合中的另一条文档，并把那条文档的字段值取出来作为当前文档的输出。这个能力在做环比计算、前后记录对比、时序数据补齐时特别好用。本文将系统地介绍$shift的语法、使用条件和典型应用场景。
一、$shift的基本语法与工作原理
$shift并不是一个可以独立使用的聚合阶段，它必须出现在$setWindowFields阶段的输出表达式中。$setWindowFields负责把文档划分成若干分区（partition），并在每个分区内按照指定的排序规则形成一条文档序列，而$shift就是在这个序列上做偏移定位。
它的语法结构如下：
{
$setWindowFields: {
partitionBy: "$stockCode", // 可选：按字段分区
sortBy: { tradeDate: 1 }, // 必须指定排序，$shift依赖文档顺序
output: {
prevClose: {
$shift: {
output: "$close", // 要取的目标字段或表达式
by: -1, // 偏移量：-1表示前一条，1表示后一条
default: null // 越界时返回的默认值
}
}
}
}
}
三个参数的含义需要准确理解。output指定要从目标文档中取出的内容，可以是一个字段路径，也可以是任意合法的表达式；by是偏移量，正数表示向后偏移，负数表示向前偏移，比如-2表示往前数第二条文档；default是可选的，当偏移后的位置超出了分区边界时，就返回这个默认值，如果不提供，越界时会直接返回缺失（missing），而不是null。
有一个容易踩的坑需要提醒：by的取值必须能转化为整数，且不能是引用文档字段的变量，也就是说它必须是编译期就能确定的常量表达式。如果你尝试写by: "$someField"，MongoDB会直接报错。这一点和某些SQL数据库中允许动态偏移的写法不同。
二、sortBy与by参数的配合细节
$shift的行为高度依赖sortBy定义的文档顺序。MongoDB会先按照sortBy在每个分区内排出一条确定的序列，然后再计算偏移。如果排序字段存在重复值，比如多条文档的排序字段完全相同，那么这些文档之间的相对顺序是不确定的，$shift取到的结果也可能不稳定。因此在设计聚合时，尽量保证排序字段在分区内唯一，或者追加一个辅助排序字段来打破平局。
下面看一个订单场景的例子。假设有一个订单集合，每条文档记录了用户ID、下单时间和订单金额，我们想计算每一单与上一单的金额差：
db.orders.aggregate([
{
$setWindowFields: {
partitionBy: "$userId",
sortBy: { createdAt: 1 },
output: {
prevAmount: {
$shift: {
output: "$amount",
by: -1,
default: 0
}
}
}
}
},
{
$setWindowFields: {
partitionBy: "$userId",
sortBy: { createdAt: 1 },
output: {
amountDelta: { $subtract: ["$amount", "$prevAmount"] }
}
}
}
])
这里用了两次$setWindowFields，因为窗口阶段的输出在同一个阶段内不能互相引用。第一个阶段取出前一单的金额，第二个阶段再做减法。虽然多了一个阶段，但逻辑清晰，性能上通常也可以接受。当然，如果只是简单计算，也可以在第二个阶段用$addFields代替，效果是一样的。
还需要注意default的设置。上面例子中分区内第一条文档没有前一条记录，我们设置default为0，这样减法运算不会因为缺失值而报错。如果不设置default，第一条文档的prevAmount字段会不存在，后续的$subtract遇到缺失值会返回null，这在某些业务里可能不符合预期，务必根据实际需求选择。
三、$shift与$lag的区别及选型建议
熟悉SQL窗口函数的开发者可能会问：MongoDB不是已经有$lag和$lead了吗？为什么还要$shift？确实，$lag可以取前一条文档的字段值，功能上有重叠，但两者有几个关键区别。
第一，$lag和$lead只能对当前文档的某个字段做偏移，而$shift的output参数支持任意表达式，你可以输出一个对象、数组，甚至是对目标文档多个字段的组合计算结果。比如你想把前一条文档的多个字段整体取出来，用$shift写一个对象表达式即可，而用$lag则需要写多次。
// 用 $shift 一次取出前一条文档的多个字段
output: {
prevDoc: {
$shift: {
output: { amount: "$amount", status: "$status", createdAt: "$createdAt" },
by: -1,
default: null
}
}
}
第二，$lag的固定偏移参数在灵活性与$shift的by本质相同，但$shift在语义上更接近通用偏移访问，配合较大的偏移量（如-7可以取一周前的数据）时，代码意图更直观。第三，从版本角度看，$shift要求MongoDB 5.1及以上，而$lag从5.0就开始支持，老版本集群升级前需要确认兼容性。
选型建议很简单：只需要取前一条或后一条的单个字段时，两者都可以，用$lag更传统；需要取多个字段的组合、或者需要一次取出跨越多条文档的数据时，$shift明显更简洁。另外，如果偏移逻辑较复杂，建议先在小数据集上验证排序的稳定性，再放到生产环境，避免因排序字段重复导致结果不可复现的问题。
四、典型应用场景与性能注意事项
$shift最常见的应用是时序分析。比如股票行情数据，计算每日收盘价相对前一交易日的涨跌幅；再比如监控指标，对比当前采样点与前一个采样点的变化量。这些场景的共同点是：数据按时间排序、需要引用相邻记录、分区维度明确（如股票代码、设备ID）。$shift配合partitionBy可以天然避免跨分区取值的错误，这一点比自己写自连接要安全得多。
另一个场景是数据补齐与检测。比如日志集合中，每条日志有状态字段，你希望标记出状态发生变化的边界记录，即当前状态与前一条状态不同的文档。用$shift取出前一条的status，再用$match过滤$ne的结果，一条管道就能完成，代码量远少于应用层实现。
性能方面需要注意：$shift本身在分区内是线性扫描，复杂度可控，但sortBy字段如果没有索引，整个窗口计算前需要先排序，数据量大时开销不小。建议为分区字段加排序字段建立复合索引，例如{ userId: 1, createdAt: 1 }，这样聚合可以直接利用索引顺序。此外，$shift只支持在$setWindowFields中使用，不能出现在$group或普通的$project中，遇到报错时先检查它是否被放错了位置。
总结一下，$shift填补了MongoDB窗口操作中灵活偏移访问的空白，配合$setWindowFields的分区与排序能力，可以优雅地解决大量相邻文档取值问题。掌握它的关键是理解三个参数的含义、保证排序稳定、合理设置默认值，再加上适当的索引支撑，就能在实际项目中放心使用。
MongoDB聚合管道$shift偏移访问修改时间：2026-09-08 06:14:42