我的 async/await 函数没有在 AWS Lambda 中等待。我错过了什么？

Question

我在 AWS Lambda 中有一个函数可以在 Stripe 中检索用户详细信息。但是函数之后的代码首先执行。我错过了什么？

在我的例子中，该函数调用一个返回客户对象的 Stripe 函数。

我认为 Stripe 函数的细节与这个特定问题无关——问题是我的 async/await 的结构：

module.exports.getUserName = async (event, context)=>{

  [code to get customerId from stripe]

  var customerName

  await stripe.customers.retrieve(customerId, function(err, customer){
      if (err){}
      else{
       customerName = customer.name
     }
  })

  console.log('This should run after stripe.customers.retrieve')

}

现在 console.log 语句首先运行。我还尝试将 Stripe 函数包装在一个单独的异步函数中，并尝试添加 try/catch。但它还没有工作。

如何确定控制台日志语句在 stripe.customers.retrieve 之后运行？

Answer 1

编辑： 我检查了 source 的 npm stripe 包。所有的函数都会返回 Promises，但是如果你另外提供一个回调，它们会被安排在下一个事件循环中被调用（在你的 console.log 运行之后立即）。

如果您要使用 Promise，您需要做的只是不提供回调。请改用Promise.then()：

await stripe.customers.retrieve(customerId).then(customer => {
   customerName = customer.name
   resolve()
}).catch(_=>{})

---

旧答案（仍然有效，但非常多余）：

await 与Promises 一起使用，它不会神奇地将异步代码转换为同步代码。我可以从老式的 function(err, customer){ 回调中看到，您的 stripe.customers.retrieve() 函数确实不返回 Promise，因此 await 实际上不会做任何事情。

您需要将其包装在一个 Promise 中以便与 async/await 一起使用：

await new Promise((resolve,reject) => { 
   stripe.customers.retrieve(customerId, function(err, customer) {
      if(!err) {
         customerName = customer.name
         resolve()
      }
   })
})