TypeError：任务不是异步js并行中的函数

Posted 2023-02-22

【中文标题】TypeError：任务不是异步js并行中的函数

【英文标题】：TypeError: task is not a function in async js parrallel

【发布时间】：2016-01-11 18:03:29

【问题描述】：

我正在尝试使用以下代码上传图像并更新数据库集合中图像的 url。

Controller.prototype.handle = function (req, res, next) 
  var id = req.params.id,
      controller = req.params.controller,
      optionalController;

  optionalController = _.clone(controller);

  // handle optional controller
  if (controller === 'newboat') 
    controller = 'boat';
   else if (controller === 'newcrew') 
    controller = 'crew';
  

  var files = req.files.files || ,
      monthYear = new Date(),          
      monthYear = [monthYear.getFullYear(), monthYear.getMonth()],      
      filename = files[0].originalFilename,
      path = files[0].path,
      extension = filename.match(EXPRESSION_EXTENSION)[1],
      destFolder = [ROOT, monthYear[0], '/', monthYear[1] ].join(''),
      destination = [ROOT, monthYear[0], '/', monthYear[1] ,'/', id, '.', extension ].join('');      

  // log info  
  //console.log(id, controller, filename, extension, destination, path);

  var opts = JSON.stringify(id: id, photo: ['/uploads/',monthYear[0], '/', monthYear[1] ,'/', id, '.', extension ].join('') );

  async.series([
                uploadImage(path,destFolder,destination), 
                ProcessUpload(optionalController, opts, res) 
              ]);
;

// write file
var uploadImage = function(path,destFolder, destination) 
    // The land of callbacks ------>>>>>> inception within inception
    mkdirp(destFolder,777,function (err)       
       fs.readFile(path, function (err, data) 
           fs.writeFile(destination, data, function (err) 
                if (err) 
                    console.log('image not uploaded..');
                    return false;
                else 
                  return true;
                
            );
        );
    ); 

;


var ProcessUpload = function(optionalController, opts, res ) 

  opts = JSON.parse(opts);

  if (optionalController === 'boat')     
    updateBoatDatabase(opts);    
  

;

/**
 * Update boat photo to database
 */
var updateBoatDatabase = function (opts, callback) 
  // save to database
  return dbServices.dbBoat.updatePhoto(opts, callback);
;

这里是被调用的数据库服务

  /**
   * Update image
   */
  updatePhoto: function (opts, callback) 
    var id = opts.id;

    // find boat by id
    this.modelClass.findById(id, function (err, model) 
      if (err || !model)
        return callback(err);      

      // set update value
      model.photo = opts.photo;

      // save
      model.save(callback);
    );
  ,

我在上传图像时收到以下错误，但图像被上传到服务器上，并且它的 url 也在数据库集合中更新。我假设它与我的回调有关，但我不确定我哪里出错了。任何有关如何调试的提示将不胜感激。

   TypeError: task is not a function
    at /home/work/bluewatertracks/node_modules/async/lib/async.js:689:13
    at iterate (/home/work/bluewatertracks/node_modules/async/lib/async.js:265:13)
    at async.forEachOfSeries.async.eachOfSeries (/home/work/bluewatertracks/node_modules/async/lib/async.js:284:9)
    at _parallel (/home/work/bluewatertracks/node_modules/async/lib/async.js:688:9)
    at Object.async.series (/home/work/bluewatertracks/node_modules/async/lib/async.js:710:9)
    at Controller.handle (/home/work/bluewatertracks/server/routers/photoUploader.js:56:9)
    at Layer.handle [as handle_request] (/home/work/bluewatertracks/node_modules/express/lib/router/layer.js:82:5)
    at next (/home/work/bluewatertracks/node_modules/express/lib/router/route.js:110:13)
    at Form.<anonymous> (/home/work/bluewatertracks/node_modules/connect-multiparty/index.js:101:9)
    at emitNone (events.js:72:20)
    at Form.emit (events.js:166:7)
    at maybeClose (/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:557:10)
    at endFlush (/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:552:3)
    at WriteStream.<anonymous> (/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:617:5)
    at emitNone (events.js:72:20)
    at WriteStream.emit (events.js:166:7)

【参考方案1】：

async.series 和大多数 async 控制流函数期望返回函数或函数数组，例如

async.series([
  function () ,
  function () 
])

您的两个函数调用，uploadImage 和ProcessUpload 的返回值是不是 函数。 async 出错了。

相反，您必须将其编写为：

async.series([
    function (callback) 
        // callback has to be called by `uploadImage` when it's done
        uploadImage(path,destFolder,destination, callback);
    ,
]);

【参考方案2】：

您还可以通过将空对象传递给bind() 来简化这一点：

async.series( [
    uploadImage.bind( null, path, destFolder, destination ),
    ProcessUpload.bind( null, optionalController, opts, res )
] );