async.series 功能未完成

Question

async.js 遇到了一个奇怪的问题。我正在解释整个场景。我在数据库中有两个表。让一个是X，有 5 行，另一个是 Y，有 2840 行。由于我的项目位于sails.js，因此我使用waterline 作为ORM。我在async.series 中运行三个函数。第一个用于从表X 中获取所有行，第二个用于从表Y 中获取所有行。在第三个函数中，我在第二个函数中获取的Y 的所有行上运行async.eachSeries，并调用外部POST api。所以整体流程是，

async.series([
    function( callback1 ){
        // Fetch all rows from `X`
    },
    function( callback1 ){
        // Fetch all rows from `Y`
    },
    function( callback1 ){
        async.eachSeries(allRowsOfY, function(item, callback2){
            // Call an external POST api.
        },
        function(err){

        });
    },
], 
function( err ){
    // Do something
});

问题是，即使Y 有 2840 行，也只进行了大约 600 个 api 调用，然后async.series 从一开始就开始运行。而这件事还在继续。为什么会这样？

Answer 1

当您拥有所有需要的数据时，将 async.series 移动到回调部分

async.series([
    function(callback) {
      // Fetch all rows from `X`
      callback(null, 'one');
    },
    function(callback) {
      // Fetch all rows from `Y`
      callback(null, ['two', 'three', 'four']);
    }
  ],
  function(err, allRowsOf) {
    async.eachSeries(allRowsOf[1], function(item, callback) { // take second element from array of results creates by async.series
        console.log('call external POST API with: ', item)
        callback() // call callback without error if everything is OK
      },
      function(err) {
        if (err) console.log('error', err)
      });
  });