{ method: "locf" } 이 있는 $fill 단계.
$fill 단계를 사용할 때 출력에 지정하는 필드는 소스 데이터에 사용된 필드와 동일한 필드입니다. 마지막 관찰 값을 기준으로 누락된 필드 값 채우기를 참조하세요.
단계 $locf $setWindowFields 내의 연산자입니다.
$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)으로 정렬하므로, 가장 이른 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
  }
]

단일 단계에서 여러 채우기 메서드 사용

$setWindowFields 단계를 사용하여 누락된 값을 채우는 경우 채우는 필드와 다른 필드의 값을 설정할 수 있습니다. 따라서 단일 $setWindowFields 단계에서 여러 채우기 메서드를 사용하고 결과를 개별 필드에 출력할 수 있습니다.

다음 파이프라인 price 선형 보간 및 last-observation-Carried-forward 메서드를 사용하여 누락된 필드를 채웁니다.

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

예시:

sortBy: { time: 1 } 는 time 필드를 기준으로 문서를 가장 오래된 것부터 최근 것까지 오름차순으로 정렬합니다.
출력 은 다음을 지정합니다.
- linearFillPrice 를 채울 대상 필드로 지정합니다.
  - { $linearFill: "$price" } linearFillPrice 필드 의 값입니다. $linearFill 은 시퀀스의 주변 price 값을 기준으로 선형 보간 을 사용하여 누락된 price 값을 채웁니다.
- locfPrice 를 채울 대상 필드로 지정합니다.
  - { $locf: "$price" } locfPrice 필드의 값입니다. locf 은 이월된 마지막 관찰을 나타냅니다. $locf 는 누락된 price 값을 시퀀스의 이전 문서 값으로 채웁니다.

출력 예시:

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

정의

구문

행동

와 의 $fill $locf비교

예시

마지막으로 관찰된 값으로 누락된 값 채우기

단일 단계에서 여러 채우기 메서드 사용

와 의 `$fill` `$locf`비교