AWS Lambda如何在SQS maxReceiveCount达阈值时触发自定义操作

Lambda完全可以获取当前SQS消息的重试次数，无需额外修改你现有的SAM配置。

具体实现方式 #

SQS会在消息的系统属性中自带ApproximateReceiveCount字段，代表该消息被消费者接收的次数：第一次被Lambda拉取时值为1，每重试一次数值+1。Lambda触发事件的Records数组中每个条目都包含该属性，直接读取即可。

以下是Node.js运行环境的参考代码：

exports.handler = async (event) => {
  // 遍历SQS消息批次
  for (const record of event.Records) {
    // 读取重试次数并转为数字
    const receiveCount = parseInt(record.attributes.ApproximateReceiveCount, 10);
    
    try {
      // 你的正常业务处理逻辑
      await yourBusinessLogic(record.body);
    } catch (error) {
      // 重试次数达到设置的maxReceiveCount=3时，触发自定义操作
      if (receiveCount === 3) {
        // 这里执行你需要的操作：调用其他Lambda、写入数据库、发送告警都可以
        await yourSpecialOperation(record);
      }
      // 必须抛出错误，让SQS感知到处理失败，继续重试或进入死信队列
      throw error;
    }
  }

  return {
    statusCode: 200,
    body: '处理完成'
  };
};

注意事项 #

• ApproximateReceiveCount为近似计数字段，误差概率极低，完全满足普通业务场景的判断需求
• 执行完自定义操作后不要吞掉错误，否则SQS会判定消息处理成功，不会按原有配置进入死信队列
• 单批次多条消息的重试次数是独立的，需要逐条读取判断，不要整批统一处理

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