类型错误:任务不是异步JS具有平行功能 [英] TypeError: task is not a function in async js parrallel
问题描述
我想上传图片,并使用下面的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屋!