Lambda Layer中@aws-sdk/client-sqs无法发送消息求助

问题现象 #

• 在Lambda Layer中调用pushError方法推送SQS消息时，日志打印到Remaining time:后Lambda直接停止执行，无任何报错，且剩余执行时间充足
• 相同代码在本地环境、直接放在Lambda函数内执行时均正常
• SQS Client可正常创建，环境变量配置齐全，权限满足SQS全操作要求

Layer核心代码 #

const crypto = require("crypto");
const { SQSClient, SendMessageCommand } = require("@aws-sdk/client-sqs");
const { getContext } = require('./context');
const { messageGroupId } = require('./constants');

const pushError = async (type, error) => {
    const context = getContext();
    const attributes = {
        type: {
            DataType: "String",
            StringValue: type,
        },
        message: {
            DataType: "String",
            StringValue: error.message,
        },
        name: {
            DataType: "String",
            StringValue: error?.name
        },
        stack: {
            DataType: "String",
            StringValue: error?.stack
        },
        functionName: {
            DataType: "String",
            StringValue: context.functionName
        },
        logGroup: {
            DataType: "String",
            StringValue: context.logGroupName
        },
        logStream: {
            DataType: "String",
            StringValue: context.logStreamName
        }
    };
    const hash = crypto.createHash("sha256");
    hash.update(JSON.stringify(attributes));
    const deduplicationId = hash.digest("hex");
    const params = {
        MessageBody: error.message,
        QueueUrl: process.env.sqsUrl,
        MessageAttributes: attributes,
        MessageDeduplicationId: deduplicationId,
        MessageGroupId: messageGroupId
    }

    const sendMessageCommand = new SendMessageCommand(params);
    try {
        const sqsClient = new SQSClient({ region: process.env.region , accessKeyId: process.env.accessKey, secretAccessKey: process.env.secretKey});
        console.log("SQS Client : ", JSON.stringify(sqsClient));
        console.log('before pushing message : ',process.env.region );
        console.log('Remaining time: ', context.getRemainingTimeInMillis());
       
        const response = await sqsClient.send(sendMessageCommand);
         
        console.log("Message sent successfully. Message ID:" , response.MessageId);
        console.log('after pushing message : ', process.env.sqsUrl);
    }
    catch (error) {
        console.error("An error occurred while alerting error: ", error);
    }
}

module.exports = { pushError };

Lambda调用Layer的代码逻辑 #

const EventEmitter = require('events');
const { errorConstants } = require('./constants');
const {pushError} = require('./sqs');

const eventEmitter = new EventEmitter();

const event = () => {
   return eventEmitter;
}

const events = [errorConstants.file, errorConstants.dynamo, errorConstants.rabbitMQ, errorConstants.email, errorConstants.fetch, errorConstants.scheduler, errorConstants.storage, errorConstants.event];

for (const event of events) {
   eventEmitter.on(event, async (error) => {
       try {
           console.log('before pushError function call ', event, error);
          await pushError(event, error);
          console.log('after pushError function call ', event, error);
       } catch (error) {
           console.log(`Error while pushing ${event} `, error);
       }
   });
};

module.exports = { event };

解决方案 #

1. 修正Layer依赖打包结构 #

Lambda Layer对Node.js依赖的目录结构有强制要求，必须将依赖放在nodejs/node_modules目录下。若打包时直接把依赖放在根目录，Layer加载时会找不到@aws-sdk/client-sqs模块，导致异步调用静默失败。

• 重新打包Layer：创建nodejs目录，在该目录下执行npm install @aws-sdk/client-sqs，然后将nodejs目录压缩为zip文件上传作为Layer。

2. 移除硬编码的凭证配置 #

代码中直接传入accessKeyId和secretAccessKey属于冗余操作，Lambda运行时会自动通过IAM角色获取合法凭证。硬编码凭证可能在Layer环境中引发权限上下文冲突，导致请求静默失败。修改SQSClient初始化代码：

const sqsClient = new SQSClient({ region: process.env.region });

3. 修复EventEmitter异步回调的生命周期问题 #

EventEmitter的异步回调不会自动等待Promise完成，若Lambda主函数执行完毕，即使回调中的异步操作仍在进行，Lambda进程也会被强制终止。需要确保主函数等待所有异步回调执行完成：

• 可以通过Promise包装事件监听逻辑，或者在Lambda主处理函数中维护任务队列，跟踪所有异步操作的状态，等待全部完成后再结束函数。

4. 启用SDK调试日志定位问题 #

在SQSClient中开启调试模式，查看请求的详细执行过程，精准定位静默失败的原因：

const sqsClient = new SQSClient({ 
    region: process.env.region,
    logger: console,
    logLevel: 'debug'
});

内容的提问来源于stack exchange，提问作者Vaidhyaprakash I