在处理物联网传感器、交易流水或系统监控指标时，我们往往不只是想知道某个时间点的瞬时值，更需要计算一段时间内的累计量，例如某条产线一天消耗的总电能、某接口十分钟内的总请求流量。传统做法是在应用层把数据拉出来循环求和，但面对千万级文档效率极低。MongoDB 5.0开始在聚合管道中提供$integral运算符，它可以直接在数据库内核里完成数值积分，避免大量数据往返。该运算符基于梯形法则（trapezoidal rule），对按时间排序的相邻文档计算面积并累加，特别适合等间隔或非等间隔的时序积分场景。
理解$integral的底层计算原理
$integral本质是对有序数据集做数值积分近似。数学上，若我们有函数 y = f(t)，积分就是曲线下的面积。数据库里 t 是时间字段，y 是待积分数值字段。运算符在相邻两文档之间用梯形面积公式：(y1 + y2) / 2 * (t2 - t1)，然后对所有相邻区间求和。它要求输入文档必须按时间字段升序排列，因为积分区间方向决定了正负号，逆序会导致面积相互抵消或错误放大。
在聚合管道中，$integral通常出现在$setWindowFields阶段或$group配合$push后的表达式里。它接收两个核心参数：input指定被积函数字段，unit指定时间单位（如"second"、"millisecond"），用来把时间差换算成对应量纲。如果文档中 input 为 null 或时间字段缺失，该区间会被跳过而非计为零，这点和$sum的零值处理不同，需要在业务里留意。
下面是一段最简单的管道示例，计算按秒采集的温度传感器在整段范围内的热量累积：
db.sensor_data.aggregate([
{ $sort: { timestamp: 1 } },
{
$setWindowFields: {
sortBy: { timestamp: 1 },
output: {
cumulativeHeat: {
$integral: {
input: "$temp_celsius",
unit: "second"
}
}
}
}
}
])
在窗口函数中按时间滑动积分
实际业务中很少只算全局积分，更多是看最近一分钟、一小时滚动积分。$setWindowFields的window参数可以定义区间，比如{ range: [-60, 0], unit: "second" }表示对每个文档计算其前六十秒到自身的积分。这种滑动窗口让仪表盘能实时显示速率积分，而无需每次全表重算。
使用窗口时需注意索引覆盖。若集合在timestamp上有升序索引，MongoDB能把排序下推，避免内存排序溢出。若窗口范围很大且文档密集，要考虑分桶（$bucket）预聚合降低基数。以下示例展示最近两分钟滑动积分：
db.flow_metrics.aggregate([
{ $sort: { ts: 1 } },
{
$setWindowFields: {
sortBy: { ts: 1 },
output: {
recentIntegral: {
$integral: {
input: "$bytes_per_sec",
unit: "second"
},
window: { range: [-120, 0], unit: "second" }
}
}
}
}
])
当时间字段不是 Date 类型而是数值时间戳时，unit依然生效，但必须保证数值单位与 unit 一致，否则积分量纲会错。例如时间戳是毫秒数，却声明 unit 为 "second"，算出的积分会缩小一千倍。这种错误不会报错，只会导致报表数值异常，排查起来很隐蔽。
与手动累加及$sum方案的对比
在$integral出现前，开发者常在$group里用$sum把数值简单相加，这其实是矩形法近似，忽略区间宽度。若采样间隔不均匀，$sum会严重高估或低估真实积分。另一种做法是应用层取出数组后用代码梯形积分，但网络传输和序列化开销大，且难以利用数据库并行能力。
我们用一张表对比三种方式：
| 方案 | 精度 | 性能 | 实现复杂度 |
|---|---|---|---|
| 应用层循环 | 高 | 低（传输全量） | 高 |
| 管道$sum | 低（矩形法） | 高 | 低 |
| 管道$integral | 高（梯形法） | 高 | 中 |
从架构角度看，把积分计算下推到MongoDB，不仅减少了应用服务器负载，也让时序类API响应更稳定。在千万文档量级下，合理使用窗口索引的$integral比拉取数据快一个数量级。要注意的是，该运算符仅支持MongoDB 5.0以上，若老版本集群需先升级或采用$group加$push后$function自定义JS计算，但那样会失去原生C++实现的高性能。
最后提醒，积分结果的单位是 input单位乘以时间单位。若 input 是 "米/秒"，unit是 "second"，结果就是 "米"。在生成业务报表时，应在字段命名或注释中标明量纲，避免下游系统误用。通过正确排序、选对单位、配合窗口，$integral能成为时序聚合中可靠且高效的积分工具。
MongoDBaggregation_pipeline$integral修改时间：2026-08-15 13:21:17