在调用Lambda函数时返回Promise

Question

我正在尝试调用Lambda函数并在完成时返回Promise，

但我收到以下错误：

“createUser（...）。那么它不是一个函数”

const createUser = (phone) => {
  return lambda.invoke({
    FunctionName: 'createUser',
    Payload: JSON.stringify({"phone": phone})
  }, (err, data) => {
    let payload = JSON.parse(data.Payload);

    if (payload.statusCode != 200) {
      Promise.reject(payload);
    }
    Promise.resolve(payload);
  })
}

createUser('')
  .then(res => console.log(res))
  .catch(err => console.log(err))

已经尝试过用声明声明一个新的Promise

let promise = new Promise((resolve, reject) => {...})

但那也不起作用......

Answer 1

aws-sdk通过大多数API方法返回的对象上的promise()属性支持promises，如下所示：

const createUser = (phone) => {
    return lambda.invoke({
        FunctionName: 'createUser',
        Payload: JSON.stringify({"phone": phone})
    }).promise();
}

createUser('555...')
.then(res => console.log)
.catch(err => console.log);

https://docs.aws.amazon.com/sdk-for-javascript/v2/developer-guide/using-promises.html

Answer 2

好吧，想通了......

我没有正确地回复承诺。

为了解决这个错误，我在一个新的Promise中声明了lambda.invoke，然后像这样返回了Promise：

const createUser = (phone) => {
   let promise = new Promise((resolve, reject) => {
    lambda.invoke({
      FunctionName: 'createUser',
      Payload: JSON.stringify({"phone": phone})
    }, (err, data) => {
      let payload = JSON.parse(data.Payload);
      if (payload.statusCode != 200) {
        reject(payload);
      } else {
        resolve(payload);
      }
    })
  })
  return promise;
}