为什么我的AWS SQS消息删除请求返回成功但消息未被删除？

核心问题原因 #

你代码中receive_message接口设置的VisibilityTimeout=0是导致问题的直接原因：

• SQS的可见性超时参数定义了消息被消费者拉取后，临时对其他消费者隐藏的时间窗口。设置为0时，你刚拉取到消息的瞬间，消息就会立刻回到待消费队列，本次拉取获得的ReceiptHandle会直接失效。
• SQS对于使用失效ReceiptHandle发起的删除请求，会返回成功响应但不会执行实际删除操作，因此会出现你遇到的"删除返回成功但消息未消失"的现象。

其他需要排查的潜在问题 #

• 确认删除消息时传入的QueueUrl和拉取消息时使用的队列地址完全一致，避免出现队列名、区域填写错误的情况
• 若你使用的是FIFO队列，确认没有相同消息分组下的未处理消息阻塞的情况
• 若你调整可见性超时后仍然出现问题，检查# do some function部分的执行耗时是否超过了你设置的可见性超时时间，处理耗时超过超时窗口也会导致ReceiptHandle提前失效。

修正后的代码示例 #

import boto3

# Create SQS client
sqs = boto3.client('sqs',
                    region_name='你的区域',
                    aws_access_key_id='你的AK',
                    aws_secret_access_key='你的SK'
                    )

queue_url = '你的队列地址'

# Receive message from SQS queue
response = sqs.receive_message(
    QueueUrl=queue_url,
    AttributeNames=[
        'All'
    ],
    MaxNumberOfMessages=10,
    MessageAttributeNames=[
        'All'
    ],
    # 按照你的业务单条消息最大处理耗时设置，留出冗余即可，示例设为30秒
    VisibilityTimeout=30,
    WaitTimeSeconds=0
)

print(len(response['Messages']))

for index, message in enumerate(response['Messages']):
    print("Index Number: ", index)
    print(message)

    receipt_handle = message['ReceiptHandle']

    # do some function

    sqs.delete_message(
         QueueUrl=queue_url,
         ReceiptHandle=receipt_handle
    )

内容的提问来源于stack exchange，提问作者Johnny John Boy