类型错误:任务不是异步JS具有平行功能 [英] TypeError: task is not a function in async js parrallel

查看:164
本文介绍了类型错误:任务不是异步JS具有平行功能的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我想上传图片,并使用下面的code更新数据库集合中的图像的URL。

  Controller.prototype.handle =功能(REQ,资源,下一个){
  VAR ID = req.params.id,
      控制器= req.params.controller,
      optionalController;  optionalController = _.clone(控制器);  //处理可选的控制器
  如果(控制器==='newboat'){
    控制器='船';
  }否则如果(控制器==='newcrew'){
    控制器='剧组';
  }  var中的文件= req.files.files || {},
      monthYear =新的日期()
      monthYear = [monthYear.getFullYear(),monthYear.getMonth()],
      文件名=文件[0] .originalFilename,
      PATH =文件[0]。路径,
      延长= filename.match(EX preSSION_EXTENSION)[1],
      destFolder = [ROOT,monthYear [0],'/',monthYear [1]]。加入(''),
      目的地= [ROOT,monthYear [0],'/',monthYear [1],'/',ID,扩展名为'。']。加入('');  //日志信息
  //console.log(id,控制器,文件名,扩展名,目的地,路径);  VAR选择采用= JSON.stringify({ID:ID,照片:['/上传/,monthYear [0],'/',monthYear [1],'/',ID,扩展名为'。']。加入( '')});  async.series([
                uploadImage(路径,destFolder,目的地)
                ProcessUpload(optionalController,选择采用,RES)
              ]);
};//写文件
VAR uploadImage =功能(路径,destFolder,目的地){
    //回调的土地------>>>>>>成立以来之内
    mkdirp(destFolder,777,功能(错误){
       fs.readFile(路径,函数(ERR,数据){
           fs.writeFile(目的地,数据,功能(错误){
                如果(ERR){
                    的console.log('形象没有上传..');
                    返回false;
                }其他{
                  返回true;
                }
            });
        });
    });};
VAR ProcessUpload =功能(optionalController,选择采用,RES){  OPTS = JSON.parse(选);  如果(optionalController ==='船'){
    updateBoatDatabase(选);
  }};/ **
 *更新船照片数据库
 * /
VAR updateBoatDatabase =功能(选,回调){
  //保存到数据库
  返回dbServices.dbBoat.updatePhoto(选,回调);
};

下面是被调用的数据库服务

  / **
   *更新图像
   * /
  updatePhoto:功能(选,回调){
    VAR ID = opts.id;    //根据ID找到的船
    this.modelClass.findById(ID,函数(ERR,型号){
      如果(ERR ||!模型)
        返回回调(ERR);      //集更新值
      model.photo = opts.photo;      // 保存
      model.save(回调);
    });
  },

我收到以下错误上传图像,但图像被上传服务器和它的URL更新数据库集合,以及上。我假设它与我的回调做的,但我真的不知道我要去的地方错了。如何调试这任何提示将AP preciated。

 类型错误:任务不是一个函数
    在/home/work/bluewatertracks/node_modules/async/lib/async.js:689:13
    在迭代(/home/work/bluewatertracks/node_modules/async/lib/async.js:265:13)
    在async.forEachOfSeries.async.eachOfSeries(/home/work/bluewatertracks/node_modules/async/lib/async.js:284:9)
    在_parallel(/home/work/bluewatertracks/node_modules/async/lib/async.js:688:9)
    在Object.async.series(/home/work/bluewatertracks/node_modules/async/lib/async.js:710:9)
    在Controller.handle(/home/work/bluewatertracks/server/routers/photoUploader.js:56:9)
    在Layer.handle [如handle_request(/home/work/bluewatertracks/node_modules/ex$p$pss/lib/router/layer.js:82:5)
    在明(/home/work/bluewatertracks/node_modules/ex$p$pss/lib/router/route.js:110:13)
    在表格<&匿名GT; (/home/work/bluewatertracks/node_modules/connect-multiparty/index.js:101:9)
    在emitNone(events.js:72:20)
    在Form.emit(events.js:166:7)
    在maybeClose(/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:557:10)
    在endFlush(/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:552:3)
    在WriteStream<&匿名GT; (/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:617:5)
    在emitNone(events.js:72:20)
    在WriteStream.emit(events.js:166:7)


解决方案

async.series 和大多数的异步控制流的功能期望返回功能或功能阵列,如:

  async.series([
  功能(){},
  功能(){}
])

你的两个函数的返回值的通话 uploadImage ProcessUpload 的功能。 异步错误了。

相反,你会写这个,就像这样:

  async.series([
    函数(回调){
        //回调有当它这样做要由`uploadImage`称为
        uploadImage(路径,destFolder,目的地,回调);
    },
]);

I am trying to upload an image and update the url of the image in the database collection using the code below.

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);
};

Here is the Database Service that is being called

  /**
   * 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);
    });
  },

I get the following error in uploading the image but the image gets uploaded on the server and its url updated on the database collection as well. I am assuming that it has to do with my callbacks but I am not really sure where I am going wrong. Any tips on how to debug this would be appreciated.

   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)

解决方案

async.series and most of the async control flow functions expect functions or arrays of functions to be returned, e.g.

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

The return values of your two function calls, uploadImage and ProcessUpload are not functions. async errors out.

Instead you would have to write this as something like:

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

这篇关于类型错误:任务不是异步JS具有平行功能的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆