/ /

$locf（表达式操作符）

定义

$locf

5.2版本新增。

最后一次的观察结果被延续了下来。将窗口中 null 和缺失字段的值设置为该字段的最后一个非 null 值。

$locf is only available in the $setWindowFields stage.

语法

The $locf expression has this syntax:

{ $locf: <expression> }

有关表达式的更多信息，请参阅表达式。

行为

If a field being filled contains both null and non-null values, $locf sets the null and missing values to the field's last known non-null value according to the sort order specified in $setWindowFields.

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

If a field being filled contains only null or missing values in a partition, $locf sets the field value to null for that partition.

Comparison of `$fill` and `$locf`

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

具有{ method: "locf" }的$fill阶段。

使用$fill阶段时，您在输出中指定的字段与源数据使用的字段相同。请参阅根据上次观察到的值填充缺失字段值。
The $locf operator inside of a $setWindowFields stage.

When you use the $locf operator, you can set values for a different field than the field used as the source data. See Use Multiple Fill Methods in a Single Stage.

示例

本页上的示例使用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 字段。

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

The following example uses the $locf operator to set missing fields to the value from the last-observed non-null value:

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

在示例中：

sortBy: { time: 1 } 按 time 以升序 (1) 对每个分区中的文档进行排序，因此最早的 time 位于最前面。
For documents where the price field is missing, the $locf operator sets the price to the last-observed value in the sequence.

示例输出：

[
  {
    _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阶段使用多种填充方法，并在不同字段中输出结果。

以下管道使用price 线性插值填充缺失的字段以及最后观察结转方法：

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