MongoDB GROUP BY와 유사한 Aggregation

Aggregation

MongoDB의 aggregation은 데이터를 처리하고 변환하기 위한 강력한 도구입니다. 

Aggregation 파이프라인은 여러 단계의 데이터 처리 단계를 포함하며, 각 단계는 데이터를 조작하고 변환하여 원하는 결과를 생성합니다. 즉 위에서부터 각 단계마다 입력한 Operators에 따라 데이터가 처리되고 처리 된 데이터가 다음 단계로 넘어간다는 것입니다.

 

Aggregation은 SQL의 GROUP BY와 유사한 작업을 수행할 수 있으며, 데이터의 그룹화, 정렬, 필터링, 변환, 계산 등 다양한 작업을 지원합니다.

 

https://www.mongodb.com/docs/manual/reference/operator/aggregation-pipeline/

Aggregation Stages — MongoDB Manual

https://www.mongodb.com/docs/manual/reference/operator/aggregation/

Aggregation Operators — MongoDB Manual

 

 

Aggregation Stage

Aggregation Stage 수집된 데이터를 통합하고 집계합니다.

 

형태

db.collection.aggregate([
    {
        <stage> 
    }, 
    ... 
])

 

예시 1) 서울에 거주하는 사용자들 중, 직업 사람들의 총 급여 출력

db.users.aggregate([
    {
        $match: {
            region: "seoul"
        }
    },
    {
        $group: {
            _id: { $getField: "job" },
            totalSalary: {
                $sum: "$salary"
            }
        }
    }
])

• $match: 해당 조건에 맞는 document만을 선택합니다. 예시에서는 'region' 필드가 'seoul'인 document만을 선택합니다.
• $group: document들을 그룹화하고, 각 그룹별로 특정 필드를 기준으로 데이터를 집계합니다. 예시에서는 'job' 필드를 기준으로 그룹화하고, 각 그룹내의 'salary'값을 모두 합하여 'totalSalary'필드로 출력하였습니다.
• $getField: 집계 표현식 중 하나로, 지정된 필드의 값을 가져옵니다. { $getField: "salary" } 를 "$salary"로 축약하여 나타낼 수 있습니다.

 

예시2) 직업 별 사용자 이름을 배열에 넣어 출력

db.users.aggregate([
    {
        $group: {
            _id: "$job",
            names: {
                $push: "$name"
            }
        }
    }
])

• 만약 사용자 이름을 넣어주는게 아니라 document를 넣어주고 싶다면 "$$ROOT"라 작성하면 됩니다.

 

 

예시3) 2023년 1월1일 부터 2024년 1월 30일까지 일마다 사람들이 지출한 금액의 평균을 내림차순으로 출력

db.users.aggregate([
    {
        $match: {
            date: {
                $gte: new ISODate("2023-01-01"),
                $lt: new ISODate("2024-01-30")
            }
        }
    }, 
    {
        $group: {
            _id: {
                $dateToString: {
                    format: "%Y-%m-%d", date: "$date"
                },
            },
            averageExpenditure: {
                $avg: "$expenditure"
            }
        }
    },
    {
        $sort: {
            averageExpenditure: -1
        }
    }
])