对多个 MongoDB 聚合函数使用 Async Parallel

Question

您好，我需要执行多个聚合查询，并将结果呈现给视图。我现在的问题是弄清楚如何确保所有查询在呈现之前完成，我遇到了 async.parallel。我一直试图弄乱它，但它不起作用。例如，这就是我现在拥有的。

    var async = require('async');
    async.parallel({
    one: function(){
        Country.aggregate([
            {
                $match: {
                name: { $in: ["USA", "China", "India", "France", "Japan"]},
                }
            },
            {
                $sort: {
                    year: 1
                }
            },
            {
                $group: {
                    _id: '$name',
                    nominalGDP: {$push: "$nominalGDP"}
                }
            }, 
            {
                $project: {
                _id: 0,
                name: "$_id",
                nominalGDP: 1
                }
            }
            ], function(err, recs){
            if(err){
                console.log(err);
            } else {
                console.log(recs);
            }
        });
    },

    two: function(){
        Country.aggregate([
            {           
                $match: {
                    $and: [
                        {name: { $in: ["USA", "China", "India", "France", "Japan"]}},
                        {year: 2017}
                    ]
                }
            },
            {
                $sort: {
                    "nominalGDP": -1
                }
            },
            {
                $project: {
                _id: 0,
                name: 1,
                'y' : '$nominalGDP'
                }
            }       
            ], function(err, recs){
            if(err){
                console.log(err);
            } else {
                console.log(recs);
            }
        });
    }
}, function(err, results){
    res.render('random', { title: 'Test', data: results.one, pie: results.two });
});

所以我有两个聚合函数，每个函数都会产生它们的结果。这两个函数正在正确打印它们的结果，但没有数据呈现到我的视图（随机）。

Answer 1

任务将 callback 函数作为参数
所以来自任务的 return 数据，它应该看起来像

task: function(callback) {
   ...
   callback(null, result);
}

在这种情况下，您可以使用 callback 作为 Country.aggregate

的第二个参数

Answer 2

Parllel 需要一个回调函数，以确保该函数已完全执行，现在是时候 return。

即使回调有2个参数， 1. Err（成功则为null） 2.数据（需要发送成功）

var async = require('async');
    async.parallel({
    one: function(cb){
        Country.aggregate([
            {
                $match: {
                name: { $in: ["USA", "China", "India", "France", "Japan"]},
                }
            },
            {
                $sort: {
                    year: 1
                }
            },
            {
                $group: {
                    _id: '$name',
                    nominalGDP: {$push: "$nominalGDP"}
                }
            }, 
            {
                $project: {
                _id: 0,
                name: "$_id",
                nominalGDP: 1
                }
            }
            ], function(err, recs){
            if(err){
               cb(err);
            } else {
               cb (null , recs);
            }
        });
    },

    two: function(cb){
        Country.aggregate([
            {           
                $match: {
                    $and: [
                        {name: { $in: ["USA", "China", "India", "France", "Japan"]}},
                        {year: 2017}
                    ]
                }
            },
            {
                $sort: {
                    "nominalGDP": -1
                }
            },
            {
                $project: {
                _id: 0,
                name: 1,
                'y' : '$nominalGDP'
                }
            }       
            ], function(err, recs){
            if(err){

                cb(err);
            } else {
               cb(null, recs);
            }
        });
    }
}, function(err, results){
    res.render('random', { title: 'Test', data: results.one, pie: results.two });
});

您可以阅读更多详细信息 https://github.com/caolan/async/blob/v1.5.2/README.md#parallel

对多个 MongoDB 聚合函数使用 Async Parallel

Using Async Parallel for multiple MongoDB aggregate functions

javascript

mongodb

node.js

aggregation-framework

async.js