$locf（集計）

項目一覧

定義
構文
動作
例

定義

$locf

バージョン 5.2 で追加。

Last observation carried forward（LOCF）法。ウィンドウ内の null および欠落しているフィールドの値として、フィールドの最後の null 以外の値を設定します。

$locfは$setWindowFieldsステージでのみ使用可能です。

構文

$locf式は次の構文をとります。

{ $locf: <expression> }

式の詳細については、「式演算子」を参照してください。

動作

入力されているフィールドにnullと null 以外の値の両方が含まれている場合、 $locfは、$setWindowFields で指定された並べ替え順序に従って、 nullと欠損値をフィールドの最後の既知の null 以外の値に設定し。

並べ替え順序において null 以外の値の前に表示されるnullと欠落しているフィールド値はnullのままになります。

入力されているフィールドにパーティション内でnullまたは欠落値のみが含まれている場合、 $locfはそのパーティションのフィールド値をnullに設定します。

と`$fill$locf`
の比較

シーケンス内の最後の観察値に基づいて欠落しているフィールド値を入力するには、次を使用します。

{ method: "locf" }を持つ$fillステージ。
$fillステージを使用する場合、出力で指定するフィールドはソースデータと同じフィールドになります。「最後に確認された値に基づいて、欠落しているフィールド値を入力する」を参照してください。
$locf$setWindowFieldsステージ内の演算子。
$locf演算子を使用すると、ソースデータとして使用されるフィールドとは異なるフィールドに値を設定できます。「 1 つのステージで複数の入力メソッドを使用する」を参照してください。

例

このページの例では、1 つの会社の株価を時間単位で追跡する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）にソートするため、最も古い time が最初になります。
priceフィールドが欠落しているドキュメントの場合、 $locf演算子はpriceをシーケンス内で最後に確認された値に設定します。

出力例:

[
  {
    _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
  }
]

1 つのステージで複数の入力メソッドを使用する

$setWindowFieldsステージを使用して欠落値を入力する場合、入力フィールドとは異なるフィールドに値を設定できます。その結果、単一の$setWindowFieldsステージで複数の入力メソッドを使用して、結果を個別のフィールドに出力できます。

次のパイプラインは、price 線形補間を使用して欠落しているフィールドを入力しますおよび last-observation-caled-forward メソッド。

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