有没有办法从 node.js 同步调用 AWS Lambda？

Question

我正在尝试通过 AWS Lambda 从现有应用程序运行特定函数，使用 JS SDK 从我的 node.js 应用程序调用 Lambda。由于我要覆盖现有函数，因此我必须保留其基本结构，即：

overwrittenFunction = function(params) {
    //get some data
    return dataArray;
}

..所以我需要得到一个我可以返回的数组，如果我想保留我使用的库的底层结构。现在，据我所知，LAMBDA调用是异步的，因此它不能够做这样的事情：

overwrittenFunction = function(params) {
    lambda.invoke(params, callback);
    function callback(err,data) {
        var dataArray = data;
    }
    return dataArray;
}

（我也尝试过类似的承诺和异步/等待）。

afaik 我现在有两个选择：以某种方式弄清楚如何进行同步 Lambda 调用，或者修改我的库/现有应用程序（如果可能，我宁愿不这样做）。

有没有办法做这样的事情并以某种方式返回我期望的值？

（我正在使用节点 v8.9.4）

Answer 1

Lambda 和 async/await 有点棘手，但以下对我有用（在生产中）：

const lambdaParams = {
    FunctionName: 'my-lambda',
    // RequestResponse is important here. Without it we won't get the result Payload
    InvocationType: 'RequestResponse',
    LogType: 'Tail', // other option is 'None'
    Payload: {
        something: 'anything'
    }
};

// Lambda expects the Payload to be stringified JSON
lambdaParams.Payload = JSON.stringify(lambdaParams.Payload);

const lambdaResult = await lambda.invoke(lambdaParams).promise();

logger.debug('Lambda completed, result: ', lambdaResult.Payload);

const resultObject = JSON.parse(lambdaResult.Payload)

把它全部包起来试试/抓住然后去镇上。

Answer 2

您可以使用异步等待，但由于 AWS 开发工具包使用节点回调模式，您需要使用内置的 promisify 包装函数。

const promisify = require('utils').promisify 
const aws = require('aws-sdk');

const lambda = aws.Lambda();
const invoke = promisify(lambda.invoke);

async function invocation(params) {
  try {
    return await invoke(params);
  } catch (err) {
    throw new Error('Somethings up');
  }
}

const data = invocation(params);