根據(jù)MongoDB文檔的說明，Map-reduce是將大量數(shù)據(jù)合并為有用的聚合結(jié)果的數(shù)據(jù)處理范例。 MongoDB使用mapReduce命令進行map-reduce操作。MapReduce通常用于處理大型數(shù)據(jù)集。

MapReduce命令

以下是基本 mapReduce 命令的語法 -

>db.collection.mapReduce(
   function() {emit(key,value);},  //map function
   function(key,values) {return reduceFunction}, {   //reduce function
      out: collection,
      query: document,
      sort: document,
      limit: number
   }
)

map-reduce函數(shù)首先查詢集合，然后將結(jié)果文檔映射到發(fā)出的鍵值對，然后根據(jù)具有多個值的鍵進行減少。

在上面的語法 -

• map是一個JavaScript函數(shù)，它將一個值與一個鍵映射并發(fā)出一個鍵值對；
• reduce是一個javascript功能，可以減少或分組具有相同鍵的所有文檔；
• out指定map-reduce查詢結(jié)果的位置；
• query指定選擇文檔的可選選擇條件；
• sort指定可選的排序條件；
• limit指定可選的最大文檔數(shù)；

使用MapReduce

請考慮存儲用戶帖子的以下文檔結(jié)構(gòu)。 該文檔存儲用戶的user_name和帖子的狀態(tài)(status)。

{
   "post_text": "yiibai tutorials is an awesome website for tutorials",
   "user_name": "maxsu",
   "status":"active"
}

現(xiàn)在，我們將在posts集上使用mapReduce函數(shù)來選擇所有status的值為active的帖子，并根據(jù)user_name分組，然后使用以下代碼對每個用戶的帖子數(shù)進行計數(shù) -

>db.posts.mapReduce( 
   function() { emit(this.user_id,1); }, 
   function(key, values) {return Array.sum(values)}, {  
      query:{status:"active"},  
      out:"post_total" 
   }
)

以上mapReduce查詢輸出以下結(jié)果 -

{
   "result" : "post_total",
   "timeMillis" : 9,
   "counts" : {
      "input" : 4,
      "emit" : 4,
      "reduce" : 2,
      "output" : 2
   },
   "ok" : 1,
}

結(jié)果表明，共有4個文檔與查詢(status的值為active)匹配，映射函數(shù)發(fā)出4個具有鍵值對的文檔，最后將具有相同鍵的reduce函數(shù)分組的映射文檔分解為2。

要查看此 mapReduce 查詢的結(jié)果，請使用 find 運算符 -

>db.posts.mapReduce( 
   function() { emit(this.user_id,1); }, 
   function(key, values) {return Array.sum(values)}, {  
      query:{status:"active"},  
      out:"post_total" 
   }

).find()

上述查詢給出以下結(jié)果，表明用戶 tom 和 maxsu 有兩個活動狀態(tài)的帖子 -

{ "_id" : "tom", "value" : 2 }
{ "_id" : "maxsu", "value" : 2 }

以類似的方式，MapReduce查詢可用于構(gòu)建大型復雜聚合查詢。 使用自定義JavaScript函數(shù)可以使用MapReduce，它非常靈活和強大。