Nodejs + Mongodb：聚合后查找数据

Question

我是Nodejs和MongoDB的新手。
这里是我的数据集的样本：

{ 
    'name': ABC, 
    'age':24, 
    'gender':male, 
    ... 
} 

一般来说，我想要做的就是利用他们找不同的数据集群前汇总数据。
具体而言，我想知道在不同年龄有多少人。然后，找到每个年龄段的人（文件）并存储它们。

这里是我的代码：

MongoClient.connect(url, function(err, db) { 
    if(err) { 
     console.log('Unable to connect to the mongoDB server. Error:', err); 
    } else { 
     db.collection('test').aggregate(
     [ 
      { $group: { _id: "$age" , total: { $sum: 1 } } }, 
      { $sort: { total: -1 } } 
     ]).toArray(function(err, result) { 
      assert.equal(err, null); 
      age = []; 
      for(var i in result) { 
       age.push(result[i]['_id']) 
      }; 
      ageNodes = {}; 
      for(var i in age) { 
       nodes = []; 
       var cursor = db.collection('test').find({'age':age[i]}); 
       // query based on aggregated data 
       cursor.each(function(err,doc){ 
        if(doc!=null){ 
         nodes.push(doc); 
        } else { 
         console.log(age[i]); 
         ageNodes[age[i]] = nodes; 
        } 
       }) 
      } 
      res.json(ageNodes); 
     }); 
    }; 
}); 

我预期的JSON格式：

{ 
    age:[different documents] 
} 

例如：

{ 
    20:[{name:A,gender:male,...},{},...], 
    30:[{name:B,gender:male,...},{},...], 
    ... 
} 

不过，我得到的是一个空的结果，所以我觉得也许它是由for循环造成的。
我不知道如何处理异步回调。

Answer 1

你只需要运行下面的管道，它使用$push到根文档（在管道$$ROOT系统变量表示）添加到每个年龄组的数组：

MongoClient.connect(url, function(err, db) { 
    if(err) { 
     console.log('Unable to connect to the mongoDB server. Error:', err); 
    } else { 
     db.collection('test').aggregate([ 
      { 
       '$group': { 
        '_id': '$age', 
        'total': { '$sum': 1 }, 
        'docs': { '$push': '$$ROOT' } 
       } 
      }, 
      { '$sort': { 'total': -1 } } 
     ]).toArray(function(err, results) { 
      console.log(results); 
      var ageNodes = results.reduce(function(obj, doc) { 
       obj[doc._id] = doc.docs 
       return obj; 
      }, {}); 
      console.log(ageNodes); 
      res.json(ageNodes); 
     }); 
    }; 
});