我已经阅读了许多有关如何链接异步函数的文章，但似乎似乎做对了！
如标题所示。我试图将mongoskin数据库调用链接在一起，以便我可以分块收集所有信息，然后最终在响应中发送累积的结果。
我的对象用户为：
var User = {
username: 'someusername',
accounts: [{name: 'account_1'}, {name: 'account_2'}]
}
对于每个帐户，我需要收集数据，然后在响应中发送累积的数据。因此，我正在使用以下for循环遍历帐户：
var promise = require('bluebird');
var db = require('mongoskin').db('mongodb://localhost/someDB');
for(var x in user.accounts){
//Fetch account data
user.accounts[x].accountData = fetchAccountData(user.accounts[x].name);
}
//Finally send the collected response
response.send(user);
函数fetchAccountData如下所示：
function fetchAccountData(screen_id){
db.collection('master')
.aggregate([
{$match: {screen_id: screen_id}}
], function(err, res){
if(err)
return null;
else{
console.log('Done', screen_id);
return res;
}
});
}
我如何将其链接以具有以下算法：
start:
for each account:
fetchDataForAccount
Finally:
Send Response
您的算法可以使用以下代码实现：
var Promise = require('bluebird');
var mongo = require('mongoskin'), db;
Promise.promisifyAll(mongo.Collection.prototype);
db = mongo.db('mongodb://localhost/someDB');
Promise.all(user.accounts.map(function(acct) {
return fetchAccountData(acct.name).then(function(data) {
acct.accountData = data;
});
}))
.then(function() {
response.send(user);
})
.catch(function(err) {
// handle error
});
function fetchAccountData(screen_id){
return db
.collection('master')
.aggregateAsync([
{$match: {screen_id: screen_id}}
]);
}
编辑：这是代码的细分
您需要做的第一件事是确保aggregate返回一个Promise而不是使用延续（例如回调）。您可以通过使用bluebird令人惊叹的promisification功能来做到这一点：）在这里，我们使用它，mongo.Collection.prototype以便在collection()被调用时将返回一个具有promise功能的collection实例。然后我们fetchAccountData 返回了所返回的承诺，aggregateAsync这样客户就可以知道何时解决该承诺。
接下来，我们映射到帐户中的每个帐户并返回一个promise，该承诺将在获取帐户数据并将其分配给帐户对象后实现。然后，我们使用Promise.all，它将返回一个“在数组中的所有项目都实现时”实现的承诺（来自文档）。
最后，我们必须使用then()“等待”，直到所有的返回的诺言都得到解决，最后将完整的用户对象发送回响应。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句