使用Lambda触发器时AWS SQS飞行中消息卡住问题咨询

你遇到的消息卡在飞行状态、无法重试进入DLQ的问题，核心是Lambda托管SQS事件源的默认处理逻辑和队列配置不匹配导致的，可按以下规则调整：

• 首先明确核心逻辑：当你使用Lambda托管SQS事件源映射时，默认情况下只要函数抛出未捕获的错误，整个批次的所有消息都会保留在飞行状态，直到队列配置的「可见性超时」自然到期后，才会重新变回可接收状态，接收次数自动+1。你当前看到的卡飞行状态，本质是这些消息还没到可见性超时的到期时间，所以不会被重新轮询。

1. 必改配置：调整SQS队列可见性超时 #

SQS队列的可见性超时必须满足以下计算规则，否则会出现计数异常、卡消息的问题：

可见性超时 = Lambda函数超时时间 * 函数最大重试次数 + 批处理窗口时间 + 至少1分钟的冗余量
以你的配置为例，假设Lambda函数超时设为1分钟，那可见性超时最低要设为 1*6 + 0.5 +1 =7.5分钟，建议直接设为10分钟，避免消息在函数还没处理完的时候就提前变回可见，导致接收次数异常累加。

2. 优化方案：修改Lambda处理逻辑加速消息流转 #

如果你批次内只有少数无效消息，不需要让整个批次的正常消息也一起等待超时重试，可以开启Lambda事件源映射的「部分批次响应」功能，调整代码逻辑：

• 遇到无效消息时不要直接抛出错误终止整个批次处理
• 遍历批次内所有消息，处理成功的直接调用SQS的DeleteMessage接口删除，处理失败的把消息ID收集起来
• 函数执行结束时返回固定结构：

{"batchItemFailures": [{"itemIdentifier": "失败消息的ID"}]}

• 这种模式下只有你标记失败的消息会被Lambda自动重置可见性，立刻进入重试流程，不需要等可见性超时到期，接收次数会正常累加，到你设置的5次阈值后自动移入DLQ。

注意事项 #

• 不需要在Lambda代码里手动修改消息的接收次数属性，该属性由SQS服务原生维护，手动修改不生效
• 只要你是在SQS队列侧配置的DLQ和最大接收次数，不需要额外在Lambda侧配置DLQ规则，次数达标后SQS会自动完成消息移动。

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