自定义SQS消息AWS Trace Header仍触发Lambda递归循环告警

1. 拆分SQS队列，切断递归链路 #

• 不再将处理后的消息放回原队列，直接创建两个独立队列：
  • 队列1：接收原始消息，触发Lambda完成时间戳添加的分组处理
  • 队列2：接收Lambda处理后的带时间戳消息，单独配置触发器（可复用原Lambda但需增加判断逻辑）
• 队列2中的消息满足lastMsgTimestamp超过2分钟条件时直接触发下游事件；不满足条件的消息放回队列2，彻底断开原循环路径

2. 添加自定义标记+配置消息过滤规则 #

• 往回发的消息中添加自定义系统属性，比如IsProcessed: "yes"，同时给原队列的Lambda触发器配置消息过滤规则：

  {
    "IsProcessed": ["no"]
  }
  

• 原队列仅触发Lambda处理未携带该标记的原始消息；处理完成的消息添加标记放回队列后，触发器不会再触发同一Lambda，改用定时任务或另一个Lambda扫描队列中满足时间条件的消息以触发下游

3. 用分布式缓存存储状态，绕开队列循环 #

• 取消回写队列的逻辑，改用ElastiCache Redis这类分布式缓存存储execId的时间戳状态：
  • Lambda读取批量消息后，将每个execId的firstMsgTimestamp和lastMsgTimestamp更新到Redis中
  • 配置一个定时触发的Lambda（比如每分钟执行一次），扫描Redis中所有lastMsgTimestamp超过2分钟的execId，触发下游事件后删除对应缓存记录
• 这种方式完全避免了队列内的消息循环发送，从根源上消除递归检测触发的可能

4. 用Lambda异步调用替代队列回写 #

• 当消息未到2分钟需要延迟处理时，不回写SQS，直接通过Lambda的异步调用自身，将处理后的消息作为事件参数传递：
  • 设置异步调用的延迟时间（比如1分钟），让Lambda延迟后再次处理该消息
  • 每次异步调用时更新lastMsgTimestamp，直到满足超时条件后触发下游事件
• 注意配置好异步调用的重试策略和死信队列，避免消息丢失

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