AWS FIFO队列存有消息却返回空队列，求助排查问题

看起来你遇到的问题在FIFO队列场景里挺常见的，结合你的代码和FIFO队列的特性，我给你梳理几个关键排查点和修复方案：

1. 确保长轮询在消费端和队列端都正确配置 #

你提到已经切换为长轮询，但从代码里看不到显式设置长轮询的参数。sqs-consumer默认是短轮询，即使队列本身开启了长轮询，消费端也需要显式指定waitTimeSeconds才能触发长轮询行为。

修改你的代码，添加长轮询及相关配置：

import { create as listenToSqsQueue } from "sqs-consumer"; 

listenToSqsQueue({ 
  queueUrl: Config.aws.sqsurl, 
  handleMessage: async function (message, done){ 
    // 建议用await确保消息处理完成再标记done，避免提前确认导致消息丢失
    try {
      await invokePoller(functionName, message);
      done();
    } catch (err) {
      console.error("消息处理失败:", err);
      done(err); // 传递错误，让sqs-consumer触发重试逻辑
    }
  }, 
  batchSize: 10,
  waitTimeSeconds: 20, // 开启长轮询，最大支持20秒
  visibilityTimeout: 300 // 根据你的Lambda处理时长调整，比如设为5分钟
}).on("empty", function() { 
  callback(undefined, "Queue is empty"); 
}).on("error", function(error: Error, message: any) { 
  console.error(error, message); 
  callback(error) 
}).start();

同时，确认你的FIFO队列本身已经开启长轮询：在AWS控制台的SQS队列配置里，找到Receive message wait time，设置为大于0的值（比如20秒）。

2. 排查MessageGroupId的分布问题 #

FIFO队列的核心特性是同一MessageGroupId的消息必须顺序处理，这意味着同一时间只有一个消费者能处理该分组下的消息。如果你的200多万条消息都属于同一个MessageGroupId：

• 即使你部署了多个消费者实例，也只有一个能拿到消息，其他实例都会持续返回空轮询
• 单消费者处理速度有限，会导致大量消息积压，同时其他消费者无消息可轮询

解决方法：

• 如果业务逻辑允许，重新设计MessageGroupId策略，将消息分散到多个分组中（比如按用户ID、业务模块拆分）
• 如果必须使用同一个分组，那只能维持单消费者实例，或者确保消费者并发数和分组数一一对应

3. 检查消息的可见性超时和处理状态 #

如果之前的消息处理流程异常，或者可见性超时设置不合理，可能导致消息被锁住无法被轮询：

• 如果可见性超时过短，消息还没处理完就重新回到队列，会引发重复处理，但不会直接导致空轮询
• 如果可见性超时过长，且之前的消费者异常退出（比如Lambda被强制终止），消息会在很长时间内处于不可见状态，导致轮询不到

你可以在AWS控制台的SQS队列监控面板查看Approximate Number of Messages Not Visible指标，如果数值很高，说明有大量消息被锁住，需要调整可见性超时，或者手动重置消息的可见性状态。

4. 确认sqs-consumer的FIFO队列兼容性 #

sqs-consumer原生支持FIFO队列，但旧版本可能存在兼容性问题。建议执行npm update sqs-consumer更新到最新版本，同时检查官方仓库是否有相关的已知issue。

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