【问题标题】:Is there a way to invoke AWS Lambda synchronously from node.js?有没有办法从 node.js 同步调用 AWS Lambda?
【发布时间】:2018-06-26 14:02:44
【问题描述】:

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

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

..所以我需要一个可以返回的数组,如果我想保持我使用的 lib 的底层结构相同。现在据我所知,Lambda 调用是异步的,因此不可能执行以下操作:

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

(我也用 promises 和 async/await 尝试过类似的事情)。

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

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

(我使用的是节点 v8.9.4)

【问题讨论】:

  • 你使用的是什么版本的node
  • @dashmug 我正在使用 v8.9.4

标签: node.js amazon-web-services asynchronous aws-lambda aws-sdk-js


【解决方案1】:

您可以使用异步等待,但由于 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);

【讨论】:

  • 但是异步函数不总是返回一个承诺吗?我的问题是我不能以一种让我将它们的值“返回”到函数之外的方式来处理承诺:/
  • 你试过了吗?
  • 我做了,它抛出一个错误:this.makeRequest 不是一个函数。 ||如果我理解正确,那么在这种情况下,您正试图让 lambda 调用返回一个承诺,对吧? Afaik,通过使用 lambda.invoke().promise()(我尝试过)在 SDK 中本机工作
  • 这就是应该如何避免“this.makeRequest is not a function”错误const invoke = promisify(lambda.invoke.bind(lambda));另外导入需要const promisify = require('util').promisify;它是'util'而不是'utils'
【解决方案2】:

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)

用 try/catch 把这一切包起来,然后去镇上。

【讨论】:

  • 我们可以在这里调用.promise(),因为大多数SDK操作返回一个AWS.Request对象:docs.aws.amazon.com/sdk-for-javascript/v2/developer-guide/…
  • 如何处理长请求?节点会超时吗?
  • 非常有帮助,谢谢。值得更多关注 InvocationType: 'RequestResponse', 我认为 - 这是我所缺少的拼图
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2018-05-23
  • 1970-01-01
  • 2019-06-30
  • 2017-07-13
  • 2015-09-20
  • 1970-01-01
相关资源
最近更新 更多