javascript - 合并和聚合具有相同模式 mongodb 的两个或多个集合的某些字段

Question

我有一些具有相同架构的集合，我想对它们执行合并+聚合。架构很简单，如下所示:

{ 'fr': 1, 'to': 1, 'wg': 213}
{ 'fr': 1, 'to': 2, 'wg': 53}
{ 'fr': 2, 'to': 2, 'wg': 5521}

以下代码适用于合并两个集合，但我想知道是否有更快的解决方案和/或可以以类似的方式合并多个集合而无需创建嵌套调用的解决方案:

var c = db.collection('first').find()

c.each(function(err, doc) {
    if (err) throw err

    if (doc == null) {
        console.log('done')
        return
    }
    db.collection('second').findOne({
        'fr': doc['fr'],
        'to': doc['to']
    }, function(err, doc2) {
        if (err) throw err

        db.collection('my_results').save({
            'fr': doc['fr'],
            'to': doc['to'],
            'wg': doc['wg'] + doc2['wg']
        }, function(err) {
            if (err) throw err
        })
    })
})

Answer 1

这里没有绝对自由的操作，因为您无法与 MongoDB 进行连接。但是您可以使用mapReduce 及其一些功能获得您想要的输出。

所以首先创建一个映射器:

var mapper = function () {

  emit( { fr: this.fr, to: this.to }, this.wg )

};

然后是一个 reducer :

var reducer = function (key,values) {

  return Array.sum( values );

};

然后运行 ​​mapReduce 操作，并将输出设置为不同的集合:

db.first.mapReduce(mapper,reducer,{ "out": { "reduce": "third" } })

请注意其中的“out”选项，即 explained in this manual section 。要点是，尽管控制台中的统计输出可能会产生误导，但“减少”语句非常重要。当我们对另一个集合运行相同的代码时就是这样:

db.second.mapReduce(mapper,reducer,{ "out": { "reduce": "third" } })

结果中实际发生的情况是，第一个操作的输出也传递到第二个操作的“reduce”阶段。

最终结果是两个集合中具有相同键值的所有值将被添加到“第三个”集合中:

{ "_id" : { "fr" : 1, "to" : 1 }, "value" : 426 }
{ "_id" : { "fr" : 1, "to" : 2 }, "value" : 106 }
{ "_id" : { "fr" : 2, "to" : 2 }, "value" : 11042 }

如果您希望 fr 和 to 成为两种可能顺序的唯一组合，或者甚至运行另一个 mapReduce 或聚合，您可以做得更奇特一些超过这些结果。