AWS SNS FIFO订阅SQS FIFO队列消息延迟超7分钟问题求助

同区域SNS到SQS的正常投递延迟在100ms以内，7分钟的延迟绝非正常网络latency导致，100%是配置或消息格式问题，可按以下路径排查：

排查思路 #

• 检查SNS FIFO主题的投递配置：确认是否误开启了投递延迟（Delivery Delay），FIFO主题默认延迟为0，如果被配置为分钟级延迟会直接导致消息投递滞后。同时确认是否开启了不必要的消息存档策略，该类策略会先将消息持久化到其他存储后再投递，可能引发延迟。
• 检查SQS订阅的过滤策略：如果配置了消息过滤规则，而你发送的测试消息不符合过滤规则，消息会被SNS直接丢弃或进入重试队列，你观测到的7分钟延迟大概率是多次重试的时间间隔。可先在SNS控制台清空订阅的Filter Policy，无过滤规则下测试投递速度。
• 检查死信队列与重试策略配置：如果SNS没有权限向订阅的SQS队列投递消息，或者SQS队列处于不可用状态，SNS会按照默认重试策略重复投递，重试间隔会随次数增加逐步拉长，最高可达数分钟。可先删除现有订阅重新创建，测试时直接用SNS控制台的发布消息功能发送测试数据，排除业务代码的消息格式问题。
• 验证FIFO消息必填参数：SNS FIFO主题要求所有发布的消息必须携带MessageGroupId参数，如果你的.NET代码发布消息时漏传该参数，消息会进入SNS的待处理队列，直到触发超时重试才会投递。AWS .NET SDK发布SNS FIFO消息的参考代码如下：

var publishRequest = new PublishRequest
{
    TopicArn = "替换为你的SNS FIFO主题ARN",
    Message = "测试消息内容",
    MessageGroupId = "test-group-001", // FIFO主题必填参数
    // 如果开启了消息自动去重，需补充MessageDeduplicationId参数
    MessageDeduplicationId = Guid.NewGuid().ToString()
};
await _amazonSNSClient.PublishAsync(publishRequest);

• 检查IAM资源权限：确认SQS队列的资源策略允许SNS主题向其发送消息，避免权限校验失败导致的投递重试，SQS侧的最小权限配置示例如下：

{
  "Effect": "Allow",
  "Principal": {
    "Service": "sns.amazonaws.com"
  },
  "Action": "sqs:SendMessage",
  "Resource": "替换为你的SQS队列ARN",
  "Condition": {
    "ArnEquals": {
      "aws:SourceArn": "替换为你的SNS主题ARN"
    }
  }
}

快速验证方案 #

1. 使用AWS控制台直接向SNS FIFO主题发布携带正确MessageGroupId的测试消息
2. 查看SNS主题监控面板的NumberOfMessagesPublished和NumberOfNotificationsDelivered指标，确认消息发布和投递的时间差
3. 如果控制台发布的消息仍然存在高延迟，直接删除现有SNS主题和SQS队列重新创建，避免历史错误配置残留影响测试结果

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