0

我有以下收藏：

{
  "_id" : ObjectId("51f1fcc08188d3117c6da351"),
  "cust_id" : "abc123",
  "ord_date" : ISODate("2012-10-03T18:30:00Z"),
  "status" : "A",
  "price" : 25,
  "items" : [{
      "sku" : "ggg",
      "qty" : 7,
      "price" : 2.5
    }, {
      "sku" : "ppp",
      "qty" : 5,
      "price" : 2.5
    }]
}

我的地图功能是：

 var map=function(){emit(this._id,this);}

出于调试目的，我覆盖了 emit 方法，如下所示：

var emit = function (key,value){
  print("emit");
  print("key: " + key + "value: " + tojson(value));
  reduceFunc2(key, toJson(value));
}

和reduce函数如下：

var reduceFunc2 = function reduce(key,values){
  var val = values;
  print("val",val);
  var items = [];
  val.items.some(function (entry){
    print("entry is:::"+entry);
    if (entry.qty>5 && entry.sku=='ggg'){
      items.push(entry)
    }
  });
  val.items = items;
  return val;
}

但是当我将地图应用为：

var myDoc = db.orders.findOne({
  _id: ObjectId("51f1fcc08188d3117c6da351")
});
map.apply(myDoc);

我收到以下错误：

emit key: 51f1fcc08188d3117c6da351 value:
{
  "_id":" ObjectId(\"51f1fcc08188d3117c6da351\")",
  "cust_id":"abc123",
  "ord_date":" ISODate(\"2012-10-03T18:30:00Z\")",
  "status":"A",
  "price":25,
  "items":[
    {
       "sku":"ggg",
       "qty":7,
       "price":2.5
    },
    {
       "sku":"ppp",
       "qty":5,
       "price":2.5
    }
  ]
}

value:: undefined
Tue Jul 30 12:49:22.920 JavaScript execution failed: TypeError: Cannot call method 'some' of undefined

你会发现它们是打印值中的一个 items 字段，它是数组类型的，即使它抛出错误也不能在未定义时调用一些，如果有人能告诉我哪里出错了。

4

1 回答 1

2

您的reduceFunc2函数有错误：

var reduceFunc2 = function reduce(key,values){
  var val = values[0]; //values is an array!!!
  // ...
}

减少函数意味着将一个元素数组，用相同的 发出，减少key到单个文档。所以，它接受一个数组。您只发出一次每个键，因此它是一个带有单个元素的数组。

现在您可以正常拨打电话了MapReduce：

db.orders.mapReduce(map, reduceFunc2, {out: {inline: 1}});

你覆盖emit函数的方式被破坏了，所以你不应该使用它。

更新。如果只有一个文档与给定键关联，Mongo 可能会跳过缩减操作，因为缩减单个文档没有意义。

的想法MapReduce是将每个文档映射到一个键值对数组中，以便在下一步进行缩减。如果与给定键关联的值超过一个，Mongo则运行一项reduce操作以将其缩减为单个文档。Mongo 期望reduce函数以与发出的元素相同的格式返回缩减的文档。这就是为什么 Mongo 可以reduce为每个键运行任意次数（最多为emits）的原因。reduce如果没有要减少的内容（例如，如果只有一个元素），也不能保证根本不会调用操作。

因此，最好将map逻辑移动到适当的位置。

更新2。无论如何，你为什么在这里使用MapReduce？您可以只查询您需要的文件：

db.orders.find({}, {
  items: {
    $elemMatch: {
      qty: {$gt: 5},
      sku: 'qqq'
    }
  }
})

更新 3.如果你真的想这样做MapReduce，试试这个：

db.runCommand({
  mapreduce: 'orders',
  query: {
    items: {
      $elemMatch: {
        qty: {$gt: 5},
        sku: 'ggg'
      }
    }
  },
  map: function map (){
    this.items = this.items.filter(function (entry) {
      return (entry.qty>5 && entry.sku=='ggg')
    });
    emit(this._id,this);
  },
  reduce: function reduce (key, values) {
    return values[0];
  },
  verbose: true,
  out: {
    merge: 'map_reduce'
  }
})
于 2013-07-30T07:56:54.767 回答