在javascript的循环中异步执行一个函数-在哪里放置defer.resolve

您所写的内容是正确的，但只承诺了外部的batchGet()。因为没有尝试承诺内部batchGet()，所以它不会对最终返回的承诺做出贡献。

你的整体模式可能是这样的…

exports.productDetailsQuery = function(options) {
    return sails.aerospike.batchGetAsync(...).then(results) {
        var promises = results.filter(function(res) {
            // Filter out any results that are not `AEROSPIKE_OK`
            ...
        }).map(function(parent) {
            // Map the filtered results to an array of promises
            return sails.aerospike.batchGetAsync(...).then(function(childData) {
                ...
            });
        });
        // Aggregate the array of promises into a single promise that will resolve when all the individual promises resolve, or will reject if any one of the individual promises rejects.
        return sails.Q.all(promises);
    });
}

…其中batchGetAsync()是batchGet()的承诺版本。

完全充实的代码将更长，但可以通过首先定义几个实用函数来保持相当简洁和可读。你可能会得到这样的结果:

// utility function for making a "key" object
function makeKey(obj) {
    return {
        ns: '', //AEROSPIKE_NAMESPACE
        set: 'products', //AEROSPIKE_SET
        key: 'pd.v1.c' + options.city_id + '.' + obj.toString()
    }
}
// promisified version of batchGet()
function batchGetAsync(obj) {
    var defer = sails.Q.defer();
    batchGet(obj, function(err, results) {
        if(err.code === status.AEROSPIKE_OK) {
            defer.resolve(results);
        } else {
            defer.reject(err);
        }
    });
    return defer.promise; 
}
var status = require('aerospike').status;
// Main routine
exports.productDetailsQuery = function(options) {
    return batchGetAsync(options.results.map(makeKey)).then(results) {
        var promises = results.filter(function(res) {
            if (res.status === status.AEROSPIKE_OK) {
                return true;
            } else if(status.AEROSPIKE_ERR_RECORD_NOT_FOUND) {
                console.log("NOT_FOUND - ", res.keys);
            } else {
                console.log("ERR - %d - ", res.status, res.keys);
            }
            return false;
        }).map(function(parent) {
            var entry = { 'primary_prod': parent },
                children = parent['children'];
            if(children) {
                return batchGetAsync(children.map(makeKey)).then(function(childData) {
                    entry.variants = childData;
                    return entry;
                });
            } else {
                return entry;
            }
        });
        return sails.Q.all(promises);
    });
}

随着新的ES6加上异步的东西和babel它更简单。您可以使用npm i -g babel npm i babel-runtime，然后使用babel test.js --optional runtime --stage 2 | node编译并运行以下命令:

import {inspect} from 'util';                                   
let testData = [                                                
  { id: 0, childIds: [1,2]},                                    
  { id: 1, childIds:[] },                                       
  { id: 2, childIds:[] }                                        
];                                                              
function dbGet(ids) {                                           
  return new Promise( r=> {                                     
    r(ids.map((id) => { return testData[id];}));                
  });                                                           
}                                                               
async function getChildren(par) {                               
  let children = await dbGet(par.childIds);                     
  par.children = children;                                      
}                                                               
async function getAll(parentIds) {                              
  let parents = await dbGet(parentIds);                         
  for (let p of parents) {                                      
    await getChildren(p);                                       
  }                                                             
  return parents;                                               
}                                                               
async function test() {                                         
  var results = await getAll([0]);                              
  console.log(inspect(results,{depth:3}));                      
}                                                               
test().then(f=>{}).catch( e=> {console.log('e',e)});