3

根据SQS 文档，最多可以发布 256KB 数据的消息。我将队列配置为 256KB 的数据，但是当我使用 boto 发布时，我的最大输出为 ~196 000 字节。对此，我从 SQS 得到以下响应：

boto.exception.SQSError: SQSError: 400 Bad Request
<?xml version="1.0"?><ErrorResponse xmlns="http://queue.amazonaws.com/doc/2012-11-05/">
<Error><Type>Sender</Type><Code>InvalidParameterValue</Code><Message>
Value for parameter       MessageBody is invalid. Reason: Message body must be shorter     than 262144 bytes.</Message>
<Detail/></Error><RequestId>dd24151b-d499-5bb1-acd0-5f776011e960</RequestId></ErrorResponse>

小python程序来说明：

from boto.sqs.message import Message
from boto.sqs.connection import SQSConnection
from boto.sqs.message import Message
import sys

sqs_conn = SQSConnection(AWS_KEY, AWS_SECRET)

data = mylong_256kb_string

print sys.getsizeof(data)
current_queue = sqs_conn.create_queue('test_temp_queue')

m = Message()
m.set_body(data)

current_queue.write(m)
4

1 回答 1

4

这是因为默认情况下，boto base64 会在发送消息之前对其有效负载进行编码，并在读取时对其进行解码。这主要是由于历史原因；在 SQS 的早期，对于 SQS 消息中可以包含的字符类型有很多限制。情况不再如此，因此可能不需要编码/解码。

要绕过它，只需使用boto.message.RawMessageclass 而不是boto.message.Message.

于 2013-07-26T18:16:17.013 回答