10

我想通过以下代码在 lambda 处理程序之外调用一个异步函数：

var client;
(async () => {
    var result =  await initSecrets("MyWebApi");
    var secret = JSON.parse(result.Payload);
    client= new MyWebApiClient(secret.API_KEY, secret.API_SECRET); 
});

async function initSecrets(secretName) {
    var input = {
    "secretName" : secretName
    };
    var result = await lambda.invoke({
       FunctionName: 'getSecrets',
       InvocationType: "RequestResponse",
       Payload: JSON.stringify(input)
    }).promise();
    return result;
}

exports.handler = async function (event, context) {

    var myReq = await client('Request');
    console.log(myReq);
};

'client' 没有被初始化。如果在处理程序中执行相同的代码，则可以完美运行。initSecrets 包含调用 AWS SecretsManager 的 getSecrets() 的 lambda 调用有没有人知道如何在处理程序之外正确调用异步函数以进行初始化？

非常感谢您的支持。

4

3 回答 3

4

我在尝试让 next-js 与 aws-serverless-express 一起工作时遇到了类似的问题。

我通过执行以下操作来修复它（使用打字稿，所以只需忽略 :any type 位）

const appModule = require('./App');
let server: any = undefined;

appModule.then((expressApp: any) => {
  server = createServer(expressApp, null, binaryMimeTypes);
});

function waitForServer(event: any, context: any){
  setImmediate(() => {
    if(!server){
      waitForServer(event, context);
    }else{
      proxy(server, event, context);
    }
  });
}

exports.handler = (event: any, context: any) => {
  if(server){
    proxy(server, event, context);
  }else{
    waitForServer(event, context);
  }
}

因此，对于您的代码，可能类似于

var client = undefined;

initSecrets("MyWebApi").then(result => {
    var secret = JSON.parse(result.Payload);
    client= new MyWebApiClient(secret.API_KEY, secret.API_SECRET)
})

function waitForClient(){
  setImmediate(() => {
    if(!client ){
      waitForClient();
    }else{
      client('Request')
    }
  });
}

exports.handler = async function (event, context) {
  if(client){
    client('Request')
  }else{
    waitForClient(event, context);
  }
};
于 2019-03-20T11:35:26.833 回答
2

这也可以通过 async/await 解决给 Node v8+

您可以像这样将配置加载到模块中...

const fetch = require('node-fetch');

module.exports = async () => {

  const config = await fetch('https://cdn.jsdelivr.net/gh/GEOLYTIX/public/z2.json');

  return await config.json();

}

然后通过 require / 执行配置模块在处理程序之外声明一个 _config 。您的处理程序必须是异步函数。_config 首先是一个承诺，您必须等待它解析为配置对象。

const _config = require('./config')();

module.exports = async (req, res) => {

  const config = await _config;

  res.send(config);

}
于 2020-01-17T20:07:06.347 回答
1

client在初始化之前被调用；var在函数完成client之前被“导出”（并调用） 。async当你打电话await client()给客户时，仍然是undefined.

编辑，尝试这样的事情

var client = async which => {
    var result =  await initSecrets("MyWebApi");
    var secret = JSON.parse(result.Payload);
    let api = new MyWebApiClient(secret.API_KEY, secret.API_SECRET); 
    return api(which) // assuming api class is returning a promise
}

async function initSecrets(secretName) {
    var input = {
    "secretName" : secretName
    };
    var result = await lambda.invoke({
       FunctionName: 'getSecrets',
       InvocationType: "RequestResponse",
       Payload: JSON.stringify(input)
    }).promise();
    return result;
}

exports.handler = async function (event, context) {

    var myReq = await client('Request');
    console.log(myReq);
};
于 2019-03-18T18:41:59.830 回答