lambda 函数中的 AWS NodeJS lambda 调用

Question

我正在尝试从另一个 lambda 函数调用 lambda 函数并获取结果以执行其余的 lambda。

函数的基本流程如下

X - main lambda function
    - process A (independent)
    - process C (need input from process B)
    - process D
    - return final dataset 
Y - Child lambda function
   - process B ( need input from process A and respond back to X )

到目前为止，这是我的代码

var AWS = require('aws-sdk');
AWS.config.region = 'us-east-1';
var lambda = new AWS.Lambda();

const GetUserCheckoutData: Handler = async (userRequest: EmptyProjectRequest, context: Context, callback: Callback) => {

    const dboperation = new UserController();
    const usercheckoutdata = new CheckOutInfo();
    const addresscontroller = new  AddressController();
    const ordercontroller = new OrderController();
    const paypalcreateorder = new PayPalController();

    const userid = await dboperation.getUserID(userRequest.invokeemailAddress);

    usercheckoutdata.useraddressdetails = await addresscontroller.GetListOfAddressByUserID(userid);
    var orderlist = new Array<Order>();
    orderlist = [];

    orderlist =  await ordercontroller.GetCurrentOrder(userid);

    console.log("Order Complete");

    var params = {
        FunctionName: 'api-ENGG-SellItem', // the lambda function we are going to invoke
        InvocationType: 'RequestResponse',
        LogType: 'Tail',
        Payload: '{ "orderlist" : xxxxxxx }'
      };

    lambda.invoke(params, (err:any, res:any) => {
        if (err) {
            callback(err);
        }

        console.log(JSON.stringify(res));

        callback(null, res.Payload);
    });

    usercheckoutdata.orderID = await paypalcreateorder.CreateOrder(userid , orderlist);
    usercheckoutdata.orderPreview = await ordercontroller.OrderPreview(userid);


    //callback(null,usercheckoutdata);
};

export { GetUserCheckoutData }

我尝试了几种不同的方法，但流程无法正常工作。交叉 lambda 函数正在执行。但无法及时得到回复。

我的 child lambda 函数演示代码

import { Handler, Context } from "aws-lambda";

const SellItem: Handler = (event, context, callback) => {

    context.callbackWaitsForEmptyEventLoop = false;
    console.log("Other Lambda Function");
    setTimeout(() => {

        callback(null, "My name is Jonathan"); 
     }, 1000 * 10); // 10 seconds delay
}

export {SellItem}

我认为由于我对 NodeJS 的了解不多，所以发生了这种情况。我猜不知道如何以正确的方式回拨电话。任何帮助将不胜感激

Answer 1

您应该将对第二个 lambda 的调用作为一个承诺，这样您就可以等待它了。

    const res = await lambda.invoke(params).promise();

    // do things with the response

lambda 函数中的 AWS NodeJS lambda 调用

AWS NodeJS lambda call within a lambda function

callback

amazon-web-services

node.js

aws-lambda