sails.js 查找具有 async.js 个并行调用的查询 - 每个都提前返回

Question

我尝试使用 .exec 回调未成功，承诺 (http://sailsjs.org/documentation/reference/waterline-orm/queries) and now async.js (https://github.com/caolan/async) 控制围绕查找查询循环的异步流。 async.each 日志输出中没有并行工作（尽管并行确实填充）。

因此，如果您的解决方案使用 .exec 回调、promises 或 async.js - 我会很乐意接受它！

我发现这个 link 给出了一些有用的示例 async.js (http://www.sebastianseilund.com/nodejs-async-in-practice)

感谢您的宝贵时间和协助。

下面是我使用异步的代码：

/**
 * @module      :: Service
 * @type {{findProfile: Function}}
 */

require('async');

module.exports = {
  getProfile: function (userId, callback) {
    var json = {};
    json.notFound = false;
    json.locations = {};
    json.sports = {};

    User.findOne({id: userId}).exec(function (err, user) {
      if (err) {
        json.notFound = true;
        json.err = err;
      }

      if (!err) {
        json.user = user;

        UserSport.find({user_id: user.id}).exec(function (err, userSports) {
          if (err) {
            sails.log.info("userSports error: " + userSports);
          }

          async.each(userSports, function (userSport, callback) {
            LocationSport.findOne({id:userSport.locationsport_id}).exec(function (err, locationSport) {
              if (locationSport instanceof Error) {
                sails.log.info(locationSport);
              }

              async.parallel(
                [
                  function (callback) {
                    Location.findOne({id:locationSport.location_id}).exec(function (err, location) {
                      if (location instanceof Error) {
                        sails.log.info(location);
                      }
                      callback(null, location);
                    });
                  },
                  function (callback) {
                    Sport.findOne({id:locationSport.sport_id}).exec(function (err, sport) {
                      if (sport instanceof Error) {
                        sails.log.info(sport);
                      }
                      callback(null, sport);
                    });
                  }
                ],
                function (err, results) {
                  if (!(results[0].id in json.locations)) {
                    json.locations[results[0].id] = results[0];
                  }

                  if (!(results[1].id in json.sports)) {
                    json.sports[results[1].id] = results[1];
                  }
                }
              ); // async.parallel

            }); // locationSport
            callback();
          }, function (err) {
            sails.log.info('each');
            sails.log.info(json);
          }); // async.each

        }); // UserSport
      }
    }); // User
  }

}

Answer 1

您的代码结构如下：

      async.each(userSports, function (userSport, callback) {

        // Whatever happen here, it runs asyncly

        callback();
      }, function (err) {
        sails.log.info('each');
        sails.log.info(json);
      }); // async.each

您正在调用回调方法，但数据处理尚未完成（运行异步）。结果，sails.log.info 被立即调用。

您应该修改代码，以便在流程完成后调用回调。即在你的 async.parallel 的结果中：

      async.each(userSports, function (userSport, outer_callback) {
        LocationSport.findOne({id:userSport.locationsport_id}).exec(function (err, locationSport) {
          //...
          async.parallel(
            [
              function (callback) {
                // ...
              },
              function (callback) {
                // ...
              }
            ],
            function (err, results) {
              // ...

              outer_callback();

            }
          ); // async.parallel

        }); // locationSport

      }, function (err) {
        sails.log.info('each');
        sails.log.info(json);
      }); // async.each

sails.js 查找具有 async.js 个并行调用的查询 - 每个都提前返回

sails.js find queries with async.js each, parallel calls - each returning early

javascript

async.js

sails.js

waterline