AWS Lambda调用SQS sendMessage偶发无响应、消息丢失求助

在Node.js环境中使用AWS SDK调用SQS的sendMessage接口，多数情况运行正常，但偶尔会出现消息丢失：调用sendMessage后既无成功响应，也无失败反馈。相关代码片段如下：

try {
const value = await sqs
  .sendMessage({
    QueueUrl: URL,
    MessageBody: JSON.stringify(msg),
    MessageAttributes: {
      type: {
        StringValue: 'doJob',
        DataType: 'String'
      }
    }
  })
  .promise();
logger.info('doJob success');
} catch (e) {
  logger.error('error in doJob: ');
}

可能成因 #

• 网络波动引发的超时未处理：AWS SDK默认超时设置可能无法覆盖偶尔的网络延迟，导致请求卡在中间状态，既不返回成功也未触发异常。当前代码未配置自定义超时，遇到网络抖动时请求可能静默失败，未进入catch块。
• 错误日志缺失关键信息：catch块仅打印固定字符串，未输出错误对象e的具体内容（如错误信息、栈跟踪），即使触发异常也无法察觉，误以为没有失败反馈。
• SDK内部未捕获的Promise异常：极端情况下，AWS SDK底层HTTP请求的某些异常可能未被正确封装进Promise的reject逻辑，绕过了try/catch。

解决办法 #

1. 配置请求超时
   初始化SQS客户端时明确设置超时时间，避免请求无限挂起：

const sqs = new AWS.SQS({
  apiVersion: '2012-11-05',
  httpOptions: {
    timeout: 30000 // 设置30秒超时
  }
});

2. 完善错误日志
   在catch块中输出完整错误信息，便于定位问题：

catch (e) {
  logger.error('error in doJob:', e.message, e.stack);
}

3. 优化SDK重试策略
   调整AWS SDK的重试配置，增强对临时网络问题的容错性：

const sqs = new AWS.SQS({
  apiVersion: '2012-11-05',
  retryDelayOptions: { base: 1000 }, // 基础重试间隔1秒
  maxRetries: 3 // 最多重试3次
});

4. 添加消息发送校验（可选）
   对于关键业务消息，可在发送后通过receiveMessage做简单验证，或利用SQS的MessageDeduplicationId实现幂等发送，确保消息入队：

try {
  const sendResult = await sqs.sendMessage({
    QueueUrl: URL,
    MessageBody: JSON.stringify(msg),
    MessageAttributes: {
      type: {
        StringValue: 'doJob',
        DataType: 'String'
      }
    },
    // 可选：启用幂等，避免重复发送
    MessageDeduplicationId: `job-${msg.id}-${Date.now()}`
  }).promise();
  logger.info('doJob success, MessageId:', sendResult.MessageId);

  // 可选：短时间内尝试接收验证（注意不要干扰正常消费）
  const receiveRes = await sqs.receiveMessage({
    QueueUrl: URL,
    MaxNumberOfMessages: 1,
    MessageAttributeNames: ['type'],
    WaitTimeSeconds: 2
  }).promise();
  if (receiveRes.Messages?.some(m => m.MessageId === sendResult.MessageId)) {
    logger.info('Message confirmed in queue');
  }
} catch (e) {
  logger.error('error in doJob:', e);
}

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