在MongoDB中,可以使用聚合管道(aggregation pipeline)對集合中的數(shù)據(jù)進行數(shù)據(jù)統(tǒng)計。聚合管道是一系列的階段(stages),每個階段都會對數(shù)據(jù)進行某種操作。以下是一些常用的聚合管道階段,用于數(shù)據(jù)統(tǒng)計:
$match
:過濾數(shù)據(jù),只保留滿足指定條件的文檔。$group
:根據(jù)指定的鍵值對文檔進行分組,并對每個分組執(zhí)行聚合操作,如求和、計數(shù)、平均值等。$sort
:對數(shù)據(jù)進行排序。$project
:選擇或排除文檔中的字段,以及對字段進行計算和轉(zhuǎn)換。$limit
:限制輸出文檔的數(shù)量。$skip
:跳過指定數(shù)量的文檔。$unwind
:將數(shù)組字段拆分為多個文檔。$lookup
:在另一個集合中查找文檔,并將它們與當(dāng)前文檔合并。以下是一個使用聚合管道進行數(shù)據(jù)統(tǒng)計的示例:
假設(shè)我們有一個名為orders
的集合,其中包含以下文檔:
[
{ "_id": 1, "customer_id": 1, "amount": 100 },
{ "_id": 2, "customer_id": 1, "amount": 200 },
{ "_id": 3, "customer_id": 2, "amount": 300 },
{ "_id": 4, "customer_id": 2, "amount": 400 },
{ "_id": 5, "customer_id": 3, "amount": 500 }
]
我們想要統(tǒng)計每個客戶的訂單總金額和訂單數(shù)量。可以使用以下聚合查詢:
db.orders.aggregate([
{
$group: {
_id: "$customer_id",
totalAmount: { $sum: "$amount" },
orderCount: { $sum: 1 }
}
},
{
$sort: { totalAmount: -1 }
}
])
這個查詢的輸出將是:
[
{ "_id": 3, "totalAmount": 500, "orderCount": 1 },
{ "_id": 2, "totalAmount": 700, "orderCount": 2 },
{ "_id": 1, "totalAmount": 300, "orderCount": 2 }
]
這個示例中,我們首先使用$group
階段按customer_id
對文檔進行分組,并計算每個分組的totalAmount
(訂單總金額)和orderCount
(訂單數(shù)量)。然后,我們使用$sort
階段按totalAmount
對結(jié)果進行降序排序。