@aws-sdk/client-sqs 在 lambda 层中不起作用

问：

我正在尝试使用 @aws-sdk/client-sqs 包将消息从 lambda 层推送到 sqs，但这不起作用，也不会抛出任何错误。它在本地和 lambda 中工作，但在尝试从 lambda 层时发生错误。

层中的代码如下：

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 };

控制台直到 Remaining time： 被打印出来，但在那之后 lambda 被停止。还有很多剩余时间，lambda 不会超时。我已经给出了 lambda 配置中代码中使用的所有 env 变量。我添加了 SQS 对 lambda 的完全访问权限 + accessKey 和 secretKey 也具有对 sqs 的完全访问权限。

调用函数如下：

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 };

在签入层和 lambda 时，sqsClient 以相同的方式正确创建