4

我有用于 mongodb mapreduce 的 node.js 路由器：

app.get('/api/facets/:collection/:groupby', function(req, res) {
    var collection = db.collection(req.params.collection);
    var groupby = req.params.groupby;
    var map = function() {
      if (!this.region) {
        return;
      }
      for (index in this.region) {
        emit(this.region[index], 1);
      }
    }
    var reduce = function(previous, current) {
      var count = 0;

      for (index in current) {
        count += current[index];
      }
      return count;
    }
    var options = {out: groupby + '_facets'};
    collection.mapReduce(map, reduce, options, function (err, collection) {
    collection.find(function (err, cursor) {
        cursor.toArray(function (err, results) {
                res.send(results);
            });            
    })
    })
});

这很好用。但我想使用我的groupby参数。当我尝试做这样的事情时：

  var map = function() {
    if (!this[groupby]) {
            return;
        }
    for (index in this[groupby]) {
            emit(this[groupby][index], 1);
        }
  }

我收到TypeError: Cannot call method 'find' of undefined。有没有办法创建这样的动态 mapreduce 函数？

谢谢。

编辑：

哇！我自己做。只需scope像这样将参数传递给 mapreduce 参数scope:{keys: groupby}，然后我就可以var key = this[keys]在 map 函数内部进行操作并改用key变量this.region。伟大的！

4

1 回答 1

3

哇！我自己解决了。我刚刚将一个范围参数传递给 mapreduce 参数。

scope:{keys: groupby}

然后我能够做到

var key = this[keys]

在 map 函数内部并使用 key 变量而不是 this.region。伟大的！

于 2013-03-19T10:01:44.130 回答