能否仅用sqs_client.send_message响应删除SQS FIFO队列消息以实现回滚？

核心结论 #

仅通过sqs_client.send_message的响应无法直接删除SQS FIFO队列中的消息。因为删除SQS消息必须使用ReceiptHandle，而这个参数只有在调用receive_message或receive_message_batch接收消息时才能获取到，send_message的响应仅返回MessageId，它不能作为删除的有效凭证。

针对你的需求的解决方案 #

你的需求是发送约10条消息，若其中一条发送失败则删除所有已成功发送的消息，这里有两种可行方案：

方案一：事后清理（通用场景） #

如果无法使用事务特性，可以通过以下步骤实现：

1. 逐条发送消息时，维护一个已成功发送的MessageId列表；
2. 一旦某条消息发送失败，立即开始清理队列：
   • 循环调用receive_message拉取队列中的消息（可设置WaitTimeSeconds=20开启长轮询，确保能拉到所有消息）；
   • 对比拉取到的消息的MessageId与之前记录的列表，收集匹配消息的ReceiptHandle；
   • 调用delete_message_batch批量删除这些匹配的消息；
   • 重复拉取-删除流程，直到队列中不再有目标MessageId的消息。

方案二：事务性批量发送（推荐，FIFO队列专属） #

SQS FIFO队列支持事务性批量操作，能直接实现「要么全成功，要么全失败」的原子性，无需事后删除：

1. 使用send_message_batch接口，给所有待发送的消息指定同一个TransactionId（同时要保证这些消息的MessageGroupId相同，因为事务内的消息必须属于同一消息组）；
2. SQS会自动保证该事务内的所有消息要么全部成功写入队列，要么全部失败回滚；
3. 示例代码（Python boto3）：

   import boto3
   import uuid
   
   sqs_client = boto3.client('sqs')
   queue_url = '你的FIFO队列URL'
   transaction_id = str(uuid.uuid4())  # 生成唯一事务ID
   message_entries = [
       {
           'Id': f'msg_{i}',
           'MessageBody': f'消息内容{i}',
           'MessageGroupId': '你的消息组ID',
           'TransactionId': transaction_id
       } for i in range(10)
   ]
   
   response = sqs_client.send_message_batch(QueueUrl=queue_url, Entries=message_entries)
   
   # 检查是否有失败条目
   if 'Failed' in response and len(response['Failed']) > 0:
       print('批量发送失败，所有消息未写入队列')
   else:
       print('所有消息发送成功')
   

注意事项 #

• TransactionId仅FIFO队列支持，标准队列无法使用该特性；
• 同一个事务内的消息必须属于同一个MessageGroupId；
• 事务的有效期为5分钟，超过后SQS会自动取消该事务。

内容的提问来源于stack exchange，提问作者Learning from masters