在mongoDB映射reduce中,我有一些代码会导致一些文档被映射,但不会被缩减。我把它归结为一个非常简单的例子
m = function(){
var a = this.visit_last_action_time.getFullYear()
var b = this.visit_last_action_time.getMonth()
var c = this.visit_last_action_time.getDate()
var key = new Date(a,b,c)
emit(key,{greeting:'hi'})
}
r = function(key,values){
var sum = 0;
for (index in values) {
sum ++
}
return {count: sum}
}
result = db.runCommand({
"mapreduce" : "piwik",
"map" : m,
"reduce" : r,
"out" : "temp2",
limit:500})
结果是
{
"result" : "temp2",
"timeMillis" : 1461,
"counts" : {
"input" : 500,
"emit" : 500,
"reduce" : 13,
"output" : 20
},
"ok" : 1
}
> db.temp2.find({})
{ "_id" : ISODate("2011-01-28T00:00:00Z"), "value" : { "count" : 2 } }
{ "_id" : ISODate("2011-01-29T00:00:00Z"), "value" : { "greeting" : "hi" } }
{ "_id" : ISODate("2011-07-11T00:00:00Z"), "value" : { "greeting" : "hi" } }
{ "_id" : ISODate("2011-07-13T00:00:00Z"), "value" : { "greeting" : "hi" } }
{ "_id" : ISODate("2011-07-15T00:00:00Z"), "value" : { "count" : 2 } }
{ "_id" : ISODate("2011-07-16T00:00:00Z"), "value" : { "count" : 7 } }
{ "_id" : ISODate("2011-07-17T00:00:00Z"), "value" : { "count" : 39 } }
{ "_id" : ISODate("2011-07-18T00:00:00Z"), "value" : { "count" : 172 } }
{ "_id" : ISODate("2011-07-19T00:00:00Z"), "value" : { "count" : 248 } }
{ "_id" : ISODate("2011-09-23T00:00:00Z"), "value" : { "count" : 3 } }
{ "_id" : ISODate("2011-09-24T00:00:00Z"), "value" : { "count" : 5 } }
{ "_id" : ISODate("2011-09-25T00:00:00Z"), "value" : { "count" : 4 } }
{ "_id" : ISODate("2011-09-26T00:00:00Z"), "value" : { "count" : 2 } }
{ "_id" : ISODate("2011-09-27T00:00:00Z"), "value" : { "count" : 2 } }
{ "_id" : ISODate("2011-09-28T00:00:00Z"), "value" : { "count" : 5 } }
{ "_id" : ISODate("2011-10-13T00:00:00Z"), "value" : { "greeting" : "hi" } }
{ "_id" : ISODate("2011-10-14T00:00:00Z"), "value" : { "greeting" : "hi" } }
{ "_id" : ISODate("2011-10-15T00:00:00Z"), "value" : { "greeting" : "hi" } }
{ "_id" : ISODate("2011-10-18T00:00:00Z"), "value" : { "greeting" : "hi" } }
{ "_id" : ISODate("2011-10-19T00:00:00Z"), "value" : { "count" : 2 } }
正如你从"嗨"中看到的,这里正在发生一些奇怪的事情。
文件怎么可能没有减少?
我使用的是mongo 2.0
文件怎么可能没有减少?
只有当您需要将两个或多个值缩减为一个值时,才会调用Reduce。
您可以在函数的签名中看到这一点。reduce()
接受一个值数组并返回一个值。
从map
发出的value
的结构应该与从reduce
返回的结构相同。
在您的情况下,您的代码违反了以下规则:reduce(key, [a]) => a
。
你需要改变两件事:
m = ...
emit(key,{count:1})
}
r = function(key,values){
var sum = 0;
for (index in values) {
sum += values[index].count
}
return {count: sum}
}
请注意发射值的结构与减少值的结构是如何相同的。