Aws Lambda 不调用子 Lambda 函数

Question

我创建了一个 lambda 函数来从 sql 表中读取数据、操作数据并调用另一个 lambda 函数将结果通过电子邮件发送给多方。

var aws = require("aws-sdk");
var sql = require("mssql");
var lambda = new aws.Lambda({ region: "eu-central-1" });

exports.handler = async (event, context, callback) => {
    let dataQuery = sqlQuery(); /*prepare the query*/
   
    let result = {};
    try{
        result = await getData(dataQuery); /*fetch data*/
    }catch (err){
        console.log(err);
        throw new Error(err);
    }
    const data = prepareRes(result.recordsets[0][0])
   
    const emails = processData(JSON.parse(data));
    const params ={
        FunctionName: "testSesSendEmail",
        InvocationType: "Event",
        Payload: '<h2>Some Sample</h2>',
        LogType        : 'None',
        };
        
    
    return emails.map(async email => {
        console.log(email.emailAddr) /* everything works fine */
        
       lambda.invoke(params, function(err,data){
           console.log('callback entered')
           if (err) {console.log(err, err.stack)}
           else {
               console.log('Lambda function 1 invoked!');
                console.log(data); 
           }
       })
       
    })
    
   
     
    
   
};

出于测试目的，我已经用虚拟数据填充了有效负载。 子 lambda 似乎没有被调用。我已经设置了必要的 Iam 策略和角色，并将它们附加到父函数。 想不通怎么回事。 感谢您的帮助。

Answer 1

您期望emails.map(...) 会返回什么？这将是一个未定义值的数组，与emails 数组的长度相同，因为您的内部回调函数不返回值。取而代之的是，您需要它返回一组承诺。

此外，来自异步 Lambda 处理程序的返回值应该是单个 Promise，而不是 Promise 数组，因此您需要将该 Promise 数组折叠为单个 Promise。执行此操作的典型方法是使用Promise.all()，但请注意other options。

试试这样的：

const promises = emails.map(email => lambda.invoke(params).promise());  
return Promise.all(promises);

请注意，此代码（以及您的代码）实际上并没有以任何有意义的方式使用 email 参数，因此您需要修复它。

另外，改变这个：

exports.handler = async (event, context, callback) => {

到这里：

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

不要在异步 Lambda 处理程序中使用（甚至提供）回调。

另外，请注意，由于InvocationType='Event'，您正在异步调用子 Lambda。这可能是您想要的，但只是想检查一下。