文档菜单
文档首页
/
MongoDB 手册
/
聚合操作
/
参考
/
运算符

$locf（聚合）

本页

  • 定义
  • 语法
  • 行为
  • 示例

定义

$locf

新版本5.2.

将最后一个观察值向前填充。在窗口中将字段的null和缺失字段值设置为最后一个非空值。窗口到字段最后一个非空值。

$locf仅在$setWindowFields阶段中可用。

语法

$locf表达式具有以下语法

{ $locf: <expression> }

有关表达式更多信息，请参阅表达式运算符。

行为

如果一个字段同时包含null和非空值，则$locf将根据在$setWindowFields中指定的排序顺序，将该字段的null和缺失值设置为该字段最后已知的非空值。

在排序顺序中出现在非空值之前的null和缺失字段值保持为null。

如果一个字段在分区中只包含null或缺失值，则$locf将该分区字段值设置为null。

比较 $fill 和 $locf

要根据序列中的最后一个观测值填充缺失的字段值，可以使用

示例

此页上的示例使用一个包含单个公司按小时间隔跟踪股价的 stock 集合。

db.stock.insertMany( [
   {
      time: ISODate("2021-03-08T09:00:00.000Z"),
      price: 500
   },
   {
      time: ISODate("2021-03-08T10:00:00.000Z"),
   },
   {
      time: ISODate("2021-03-08T11:00:00.000Z"),
      price: 515
   },
   {
      time: ISODate("2021-03-08T12:00:00.000Z")
   },
   {
      time: ISODate("2021-03-08T13:00:00.000Z")
   },
   {
      time: ISODate("2021-03-08T14:00:00.000Z"),
      price: 485
   }
] )

集合中的一些文档缺少 price 字段。

用最后观察到的值填充缺失值

以下示例使用$locf运算符将缺失字段设置为最后观察到的非null值

db.stock.aggregate( [
   {
      $setWindowFields: {
        sortBy: { time: 1 },
        output: {
           price: { $locf: "$price" }
        }
      }
    }
] )

在示例中

  • sortBy: { time: 1 } 排序每个分区中的文档，按time升序（1），因此最早的时间排在前面。

  • 对于缺失price字段的文档，$locf运算符将该字段的值设置为序列中的最后观察到的值。

示例输出

[
  {
    _id: ObjectId("62169b65394d47411658b5f5"),
    time: ISODate("2021-03-08T09:00:00.000Z"),
    price: 500
  },
  {
    _id: ObjectId("62169b65394d47411658b5f6"),
    time: ISODate("2021-03-08T10:00:00.000Z"),
    price: 500
  },
  {
    _id: ObjectId("62169b65394d47411658b5f7"),
    time: ISODate("2021-03-08T11:00:00.000Z"),
    price: 515
  },
  {
    _id: ObjectId("62169b65394d47411658b5f8"),
    time: ISODate("2021-03-08T12:00:00.000Z"),
    price: 515
  },
  {
    _id: ObjectId("62169b65394d47411658b5f9"),
    time: ISODate("2021-03-08T13:00:00.000Z"),
    price: 515
  },
  {
    _id: ObjectId("62169b65394d47411658b5fa"),
    time: ISODate("2021-03-08T14:00:00.000Z"),
    price: 485
  }
]

在单个阶段中使用多种填充方法

当使用$setWindowFields阶段填充缺失值时，可以为不同于填充字段的字段设置值。因此，可以在单个$setWindowFields阶段中使用多种填充方法，并将结果输出到不同的字段。

以下管道使用线性插值和最近观测值前移方法填充缺少的价格字段。

db.stock.aggregate( [
   {
      $setWindowFields:
         {
            sortBy: { time: 1 },
            output:
               {
                  linearFillPrice: { $linearFill: "$price" },
                  locfPrice: { $locf: "$price" }
               }
         }
   }
] )

在示例中

  • sortBy: { time: 1 }按时间字段以升序对文档进行排序，从最早到最新。

  • 输出指定

    • linearFillPrice作为要填充的目标字段。

      • { $linearFill: "$price" }是linearFillPrice字段的值。$linearFill根据序列中周围的价格值使用线性插值填充缺少的价格值。

    • locfPrice作为要填充的目标字段。

      • { $locf: "$price" }是locfPrice字段的值。locf代表最近观测值前移。$locf使用序列中前一个文档的值填充缺少的价格值。

示例输出

[
  {
    _id: ObjectId("620ad555394d47411658b5ef"),
    time: ISODate("2021-03-08T09:00:00.000Z"),
    price: 500,
    linearFillPrice: 500,
    locfPrice: 500
  },
  {
    _id: ObjectId("620ad555394d47411658b5f0"),
    time: ISODate("2021-03-08T10:00:00.000Z"),
    linearFillPrice: 507.5,
    locfPrice: 500
  },
  {
    _id: ObjectId("620ad555394d47411658b5f1"),
    time: ISODate("2021-03-08T11:00:00.000Z"),
    price: 515,
    linearFillPrice: 515,
    locfPrice: 515
  },
  {
    _id: ObjectId("620ad555394d47411658b5f2"),
    time: ISODate("2021-03-08T12:00:00.000Z"),
    linearFillPrice: 505,
    locfPrice: 515
  },
  {
    _id: ObjectId("620ad555394d47411658b5f3"),
    time: ISODate("2021-03-08T13:00:00.000Z"),
    linearFillPrice: 495,
    locfPrice: 515
  },
  {
    _id: ObjectId("620ad555394d47411658b5f4"),
    time: ISODate("2021-03-08T14:00:00.000Z"),
    price: 485,
    linearFillPrice: 485,
    locfPrice: 485
  }
]

返回

$ln

下一步

$log