Middy.js SQS队列验证失败致DLQ无限循环的问题排查

异常成因 #

1. 中间件执行顺序与错误处理逻辑不匹配 #

你的Middy配置中，validator中间件在sqsPartialBatchFailure之前执行：

middy(sqsEventLambdaHandler)
  .use(eventNormalizerMiddleware())
  .use(validator({ eventSchema: transpileSchema(sqsEventLambdaEventSchema) }))
  .use(sqsPartialBatchFailure()); // 位于验证器之后

当SQS消息触发validator验证失败时，验证器会直接抛出未被捕获的错误，这个错误会中断后续中间件的执行（包括sqsPartialBatchFailure），导致Lambda整体返回Runtime.Unknown错误（对应CloudWatch的报错）。

SQS的重试规则是：如果Lambda返回非成功状态，会将整个批次的消息重新入队重试。由于错误消息从未被标记为“单独失败”，每次重试都会触发同样的验证失败，最终陷入无限循环。

2. 主动抛错时的正常逻辑 #

当你在sqsEventLambdaHandler内部主动抛出错误时，错误会被sqsPartialBatchFailure中间件捕获：

• 该中间件会生成符合SQS部分批次失败规范的返回结果（包含batchItemFailures数组，标记失败消息的messageId）
• Lambda返回成功状态，SQS会根据返回的失败列表，将对应的消息直接移至DLQ，不会重试整个批次，因此消息只会进入DLQ一次。

解决建议 #

添加一个自定义错误处理中间件，捕获validator抛出的验证错误，将其转换为SQS部分批次失败的格式，确保sqsPartialBatchFailure能正确处理：

// 自定义验证错误处理中间件
const handleValidationFailures = () => {
  const onError = async (request) => {
    // 识别Middy validator抛出的验证错误
    if (request.error?.name === 'ValidationError' && request.event.Records) {
      // 标记当前批次所有消息为失败（或根据验证结果定位具体错误消息）
      request.response = {
        batchItemFailures: request.event.Records.map(record => ({
          itemIdentifier: record.messageId
        }))
      };
      // 清除错误，让Lambda返回成功状态
      delete request.error;
    }
  };
  return { onError };
};

// 更新Middy配置，将该中间件放在validator之后、sqsPartialBatchFailure之前
middy(sqsEventLambdaHandler)
  .use(eventNormalizerMiddleware())
  .use(validator({ eventSchema: transpileSchema(sqsEventLambdaEventSchema) }))
  .use(handleValidationFailures()) // 新增错误处理
  .use(sqsPartialBatchFailure());

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