我在Express中有一个路由,我想在其中执行一系列异步操作,然后在满足某些条件时向数据库添加一些数据。到目前为止,它看起来像这样(index.js):
router.post('/distributor/:id/upload', upload.single('file'), function
(err,req, res, next ) {
if (err) {
console.log(req);
console.log(req.file);
console.error(err);
return res.sendStatus(500);
}
next()
}, function (req, res, next) {
// console.log(req.file);
csv()
.fromFile(req.file.path)
.subscribe((json)=>{
// console.log(json)
return new Promise((resolve,reject)=>{
let product = new Item(json.Title);
product.distributor_id = req.params.id
product.SKU = json.SKU
product.UPC = json.UPC
product.Price = json.Price
return resolve(product)
}).then((product) => {
// console.log(product)
//async request to external API
var productInfo = getPriceandASIN.getPriceandASIN(product.UPC)
return productInfo
}).then((info) => {
console.log(info)
console.log(product)
//a bunch of other stuff I don't need to worry about yet
// return res.end()
})
});
})
如果我只是console.log(info),我会得到预期的响应,即为集合中的每个项调用上一个异步函数的结果。但是,如果我还尝试使用console.log(product),那么整个函数就会中断,我只获取集合中第一个项目(而不是产品)的信息,而没有其他内容。是什么导致了这种行为?我认为有一些事情我根本不理解解决承诺,但我不知道从医生那里得到什么。