聚合管道aggregate

Me_Kun 發(fā)布于2019-06-26 17:49 / 918人閱讀

摘要：聚合管道介紹的聚合管道將文檔在一個(gè)管道處理完畢后將結(jié)果傳遞給下一個(gè)管道處理。它是數(shù)據(jù)聚合的一個(gè)新框架，其概念類似于數(shù)據(jù)處理的管道。

聚合管道aggregate

aggregate介紹

MongoDB的聚合管道將MongoDB文檔在一個(gè)管道處理完畢后將結(jié)果傳遞給下一個(gè)管道處理。管道操作是可以重復(fù)的。管道在Unix和Linux中一般用于將當(dāng)前命令的輸出結(jié)果作為下一個(gè)命令的參數(shù)。
aggregation 它是數(shù)據(jù)聚合的一個(gè)新框架，其概念類似于數(shù)據(jù)處理的管道。每個(gè)文檔通過一個(gè)由多個(gè)節(jié)點(diǎn)組成的管道，每個(gè)節(jié)點(diǎn)有自己特殊的功能（分組、過濾等），文檔經(jīng)過管道處理后，最后輸出相應(yīng)的結(jié)果。管道基本的功能有兩個(gè)：
一是對(duì)文檔進(jìn)行“過濾”，也就是篩選出符合條件的文檔
二是對(duì)文檔進(jìn)行“變換”，也就是改變文檔的輸出形式
其他的一些功能還包括按照某個(gè)指定的字段分組和排序等。而且在每個(gè)階段還可以使用表達(dá)式操作符計(jì)算平均值和拼接字符串等相關(guān)操作。管道提供了一個(gè)MapReduce 的替代方案，MapReduce使用相對(duì)來說比較復(fù)雜，而管道的擁有固定的接口(操作符表達(dá)),使用比較簡單，對(duì)于大多數(shù)的聚合任務(wù)管道一般來說是首選方法。

管道操作符介紹

$project：包含、排除、重命名和顯示字段
$match：查詢，需要同find()一樣的參數(shù)
$limit：限制結(jié)果數(shù)量
$skip：忽略結(jié)果的數(shù)量
$sort：按照給定的字段排序結(jié)果
$group：按照給定表達(dá)式組合結(jié)果
$unwind：分割嵌入數(shù)組到自己頂層文件
$geoNear：返回基于接近地理空間點(diǎn)的有序的文檔流

組聚合操作符介紹

$addToSet：返回在該組中的每個(gè)文檔所選擇的字段的所有唯一值的數(shù)組
$first：返回組中的第一個(gè)值
$last：返回組中的最后一個(gè)值
$max：返回組中的最大值
$min：返回組中的最小值
$avg：返回組中的平均值
$push：返回在該組中的每個(gè)文檔所選擇的字段的所有值的數(shù)組
$sum：返回組中的匯總值

#使用管道可以將多種不同的聚合統(tǒng)計(jì)記錄同時(shí)返回

db.person.aggregate([{$group:{

      _id:"$name",
      count:{$sum:1},
      total:{$sum:"$age"},
      max:{$max:"$age"},
      min:{$min:"$age"},
      avg:{$avg:"$age"}
     }}])

{ "_id" : "jason", "count" : 2, "total" : 58, "max" : 30, "min" : 28, "avg" : 29}
{ "_id" : "lorraine", "count" : 2, "total" : 47, "max" : 25, "min" : 22, "avg" :23.5 }