如何使用boto3向SQS发送压缩消息？遇字节类型报错求助

可以通过boto3向SQS发送压缩消息，核心是把压缩后的字节数据转换为SQS接受的字符串格式。针对你遇到的字节类型报错问题，具体实现方案如下：

实现步骤 #

• 对原始消息内容进行压缩（推荐使用zlib或gzip）
• 将压缩后的字节流通过base64编码转为字符串，作为MessageBody参数传入
• 接收消息时，反向执行解码和解压操作还原原始内容

发送压缩消息示例代码

import boto3
import zlib
import base64

# 初始化SQS客户端
client = boto3.client('sqs', region_name="us-east-1")
queue_url = "你的队列URL"
delay = 0

# 原始消息内容
original_msg = "需要发送的大文本消息内容"

# 压缩流程：字符串转字节 -> 压缩 -> base64编码转字符串
compressed_bytes = zlib.compress(original_msg.encode('utf-8'))
message_body = base64.b64encode(compressed_bytes).decode('utf-8')

# 发送消息
response = client.send_message(
    QueueUrl=queue_url,
    MessageBody=message_body,
    DelaySeconds=delay
)
print("消息发送成功，MessageId:", response['MessageId'])

接收并解压消息示例代码

# 接收消息
response = client.receive_message(
    QueueUrl=queue_url,
    MaxNumberOfMessages=1
)

if 'Messages' in response:
    for msg in response['Messages']:
        # 解压流程：base64解码转字节 -> 解压 -> 字节转字符串
        compressed_bytes = base64.b64decode(msg['Body'])
        original_msg = zlib.decompress(compressed_bytes).decode('utf-8')
        print("还原后的原始消息:", original_msg)
        
        # 处理完成后删除消息（可选操作）
        client.delete_message(
            QueueUrl=queue_url,
            ReceiptHandle=msg['ReceiptHandle']
        )

关键说明 #

• SQS的send_message接口要求MessageBody必须为字符串类型，直接传入字节会触发你遇到的类型错误
• 使用base64编码是因为它能将任意字节数据安全转换为ASCII字符串，避免编码和解码过程中的数据丢失
• 若偏好gzip压缩，只需将代码中的zlib模块替换为gzip模块，实现逻辑完全一致

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