$locf(집계)
정의
$locf버전 5.2에 추가되었습니다.
마지막 관찰이 이월되었습니다.
null및 창의 누락된 필드에 대한 값을 필드의 null이 아닌 마지막 값으로 설정합니다.$locf는$setWindowFields스테이지에서만 사용할 수 있습니다.
구문
$locf 표현식의 구문은 다음과 같습니다.
{ $locf: <expression> }
표현식에 대한 자세한 내용은 표현식을 참조하세요 .
행동
채워지는 필드에 null 값과 null이 아닌 값이 모두 포함되어 있는 경우 $locf 는 null 및 누락된 값을 $setWindowFields 에 지정된 정렬 순서에 따라 필드의 마지막으로 알려진 null이 아닌 값으로 설정합니다.
null 그리고 누락된 값이 정렬 순서에서 null이 아닌 값 앞에 나타나는 경우 null 상태로 유지됩니다.
채워지는 필드에 파티션 에 null 값만 있거나 누락된 값이 있는 경우 $locf 는 해당 파티션에 대해 필드 값을 null (으)로 설정합니다.
와 의 $fill $locf비교
시퀀스에서 마지막으로 관찰된 값을 기반으로 누락된 필드 값을 채우려면 다음을 사용할 수 있습니다.
{ 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 } ]