Koa-内置函数和异步/等待中的错误处理

问题描述

在我的app.js中，我有以下...

app.use(async (ctx,next) => {
  try {
    await next()
  } catch (err) {
    ctx.status = 400
    ctx.body = `Uh-oh: ${err.message}`
    console.log('Error handler:',err.message)
  }
});

app.use(router());

然后在我定义的路线中...

router.post('/',retrieve);

例如，如果我在retrieve内抛出错误，它将冒泡到app.js，例如...

const retrieve = async ctx => {
  throw new Error('test');
};

我知道...

嗯哦：测试

现在让我们说我有一个这样的函数，我想抛出一个错误...

const retrieve = async ctx => {
  await s3.createMultipartUpload({
    Bucket: "test",Key: "testName",ContentType: "contentType"
  },(err,mpart) => {
    throw new Error("test");
  });
}

它不会冒起app.js，而是显示以下内容...

错误：测试 在Response.s3.createMultipartUpload ....

为什么这不会冒泡到app.js？我该怎么办？

解决方法

我解决问题的方法是使用promise格式...

await s3.createMultipartUpload({
  Bucket: "test",Key: "testName",ContentType: "contentType"
})
.promise()
.then(data => {
  //Do Stuff
}).catch(err => { throw new Error('test') });