为何我的Lambda会定期收到SQS转发的s3:TestEvent测试事件？

从你提供的事件内容来看，这条s3:TestEvent消息的ApproximateReceiveCount为3，说明它一直在SQS队列中重复被拉取，而非新生成的测试事件。以下是可能的原因和对应的排查/解决步骤：

可能原因 #

• Lambda处理失败导致消息重回队列：如果你的Lambda函数在处理这条测试事件时抛出异常（比如JSON解析错误、逻辑报错），SQS会认为消息未被成功处理，在可见性超时到期后将消息重新放回队列，触发Lambda再次执行。
• 未正确确认消息处理完成：Lambda处理SQS事件时，默认会在函数成功执行完毕后自动删除消息，但如果函数提前退出、超时或者抛出未捕获的错误，SQS不会收到确认，消息会再次变为可见。
• SQS可见性超时设置过短：如果队列的可见性超时小于Lambda的最大执行时间，Lambda还没处理完消息，消息就会重新回到队列，导致重复触发。
• 测试消息未被手动清理：S3在配置事件通知时会发送一条测试消息，若这条消息未被正确处理删除，就会一直在队列中循环重试。

排查与解决步骤 #

1. 检查Lambda执行日志
   查看CloudWatch日志，确认处理该测试事件时是否有报错（比如body解析失败：注意事件中body的JSON存在转义，需确保Lambda能正确解析嵌套的JSON字符串）。如果是解析问题，修复代码中的JSON处理逻辑。

2. 手动清理队列中的测试消息
   进入SQS控制台，找到目标队列，查看消息列表，定位到这条s3:TestEvent消息并手动删除，阻止其继续触发Lambda。

3. 调整SQS配置

   • 确认队列的可见性超时设置大于Lambda函数的最大执行时间（比如Lambda超时设为5分钟，可见性超时设为6分钟）。
   • 配置死信队列（DLQ）：将多次处理失败的消息转移到DLQ，避免无限占用队列资源。

4. 优化Lambda处理逻辑
   在代码中添加判断逻辑，当检测到事件类型为s3:TestEvent时，直接跳过业务处理并确保函数正常执行完毕，让SQS自动删除这条消息：

   # 示例Python代码片段
   import json
   
   def lambda_handler(event, context):
       for record in event['Records']:
           body = json.loads(record['body'])
           if body['Event'] == 's3:TestEvent':
               print("Received S3 test event, skipping processing")
               continue
           # 处理正常S3事件逻辑
       return {
           'statusCode': 200,
           'body': json.dumps('Processed successfully')
       }
   

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