要删除 AWS SQS 中的消息,您可以使用 AWS SDK 提供的 deleteMessage
方法。下面是一个使用 Python Boto3 SDK 的示例代码:
import boto3
# 创建 SQS 客户端
sqs = boto3.client('sqs', region_name='us-west-2')
# 删除消息
queue_url = 'https://sqs.us-west-2.amazonaws.com/123456789012/my-queue'
receipt_handle = 'AQEBzb3gY5Nz...'
response = sqs.delete_message(
QueueUrl=queue_url,
ReceiptHandle=receipt_handle
)
print(response)
在上面的代码中,您需要提供队列的 URL 和消息的 ReceiptHandle。ReceiptHandle 是在接收消息时返回的唯一标识符。
请确保您已正确配置 AWS 身份验证凭据,并已安装 Boto3 库。