컬렉션에 저장된 문서의 일일 평균값(mean daily average)을 계산하려면 aggregate() 메서드를 사용합니다. 집계 파이프라인 안에서 $project와 $group 단계를 조합하면 원하는 결과를 손쉽게 얻을 수 있습니다.
예제: 컬렉션 생성
먼저 다음과 같이 문서가 담긴 컬렉션을 만들어 보겠습니다.
> db.demo451.insertOne({
... DueDate:new ISODate("2020-03-15T10:50:35.000Z"),
... Value: 10
... }
... );
{
"acknowledged" : true,
"insertedId" : ObjectId("5e7b5c5d71f552a0ebb0a6e9")
}
> db.demo451.insertOne({
... DueDate:new ISODate("2020-03-14T10:50:35.000Z"),
... Value: 10
... }
... );
{
"acknowledged" : true,
"insertedId" : ObjectId("5e7b5c5d71f552a0ebb0a6ea")
}
> db.demo451.insertOne({
... DueDate:new ISODate("2020-03-13T10:50:35.000Z"),
... Value: 10
... }
... );
{
"acknowledged" : true,
"insertedId" : ObjectId("5e7b5c5d71f552a0ebb0a6eb")
}
저장된 문서 확인하기
find() 메서드를 사용하면 컬렉션의 모든 문서를 조회할 수 있습니다.
> db.demo451.find();
위 쿼리는 다음과 같은 결과를 출력합니다.
{ "_id" : ObjectId("5e7b5c5d71f552a0ebb0a6e9"), "DueDate" : ISODate("2020-03-
15T10:50:35Z"), "Value" : 10 }
{ "_id" : ObjectId("5e7b5c5d71f552a0ebb0a6ea"), "DueDate" : ISODate("2020-03-
14T10:50:35Z"), "Value" : 10 }
{ "_id" : ObjectId("5e7b5c5d71f552a0ebb0a6eb"), "DueDate" : ISODate("2020-03-
13T10:50:35Z"), "Value" : 10 }
일일 평균값 계산 쿼리
다음은 컬렉션에 기록된 문서의 일일 평균값을 구하는 집계 쿼리입니다.
> db.demo451.aggregate({
... $match: {
... DueDate: {
... $lt: new ISODate()
... }
... }
... }, {
... $group: {
... _id: null,
... olderDate: {
... $min: "$DueDate"
... },
... sumValue: {
... $sum: "$Value"
... }
... }
... }, {
... $project: {
... _id: 0,
... averageValue: {
... $divide: ["$sumValue", {
... $divide: [{
... $subtract: [new ISODate(), "$olderDate"]
... }, 1000 * 60 * 60 * 24]
... }]
... }
... }
... })
실행 결과는 다음과 같습니다.
{ "averageValue" : 2.475558456547562 }
쿼리 동작 방식 살펴보기
이 집계 파이프라인은 세 단계로 구성되어 있으며, 각 단계는 다음과 같은 역할을 합니다.
- $match: 현재 시간보다 이전(즉, DueDate가 과거)인 문서만 필터링하여 대상 문서를 추립니다.
- $group: 전체 문서를 하나의 그룹으로 묶어 가장 오래된 날짜($min)와 값(Value)의 합계($sum)를 계산합니다.
- $project: 값의 총합을 경과 일수로 나누어 일일 평균값을 산출합니다. 이때 두 날짜의 차이는 밀리초 단위로 반환되므로, 1000 * 60 * 60 * 24로 나누어 '일(day)' 단위로 변환한 뒤 평균을 구합니다.
이처럼 MongoDB의 집계 프레임워크를 활용하면 복잡한 시간 기반 통계도 파이프라인만으로 간결하게 처리할 수 있습니다.