异步/等待云上传不起作用

Question

我尝试了几种不同的方法，基本上我想从我的路由中取出云端上传代码并将其放入我的路由调用的函数中以使代码更干净。但由于某种原因，我无法让 async/await 工作/等待上传完成后再完成。

这是我的路线示例：

var fieldsUpload = upload.fields([{ name: 'image1', maxCount: 1 }, { name: 'image2', maxCount: 1 }])
router.post('/upload', fieldsUpload, async function (req, res, next) {

   var url1 = await uploadToCloudinary(req.files['image1'][0].path);
   console.log("Cloudinary url: " + url1);
   var url2 = await uploadToCloudinary(req.files['image2'][0].path);
   console.log("Cloudinary url: " + url2);


   res.send("Succesfull Upload"); 

});

这是我的功能：

async function uploadToCloudinary(image) {
   try{
      let url = await cloudinary.v2.uploader.upload(image);
   }
   catch(err){ console.log(err)}
}

// function uploadToCloudinary(image) {
//    cloudinary.v2.uploader.upload(image, function(error, result) {
//       if(error) {
//          console.log(error);
//       }
//       else {
//          console.log("Succesfully uploaded image to cloudinary!")
//          return result.secure_url;
//       }
//    });
// }

我把之前的注释掉了，所以你可以看到我尝试让函数不是异步的，只是在回调之后返回，并且在路由中有等待，但也没有工作。我也不认为我应该在函数和路由中都需要等待，但尝试这样看看它是否有效。

不知道我错过了什么/做错了什么。

Answer 1

因为异步函数使用 Promise 运行，而 Cloudinary SDK 函数返回回调，所以您的 uploadToCloudinary 应该如下所示：

function uploadToCloudinary(image) {
  return new Promise((resolve, reject) => {
    cloudinary.v2.uploader.upload(image, (err, url) => {
      if (err) return reject(err);
      return resolve(url);
    })
  });
}