Question

默认情况下, 在信件发送到 SQS 之前, boto 在 Base64 编码信件。示例代码 :

conn = boto.connect_sqs( access_key_id ,  secret_key ) 
q = conn.get_queue( myqueue )
m = Message()
m.set_body( hello! )
q.write(m)

将信件 () 替换为 RawMessage (), 我可以将原始信件发送到队列中, 无需编码。但我如何在不解码的情况下读取队列中的信件? 如果我使用以下代码 :

rs = q.get_messages(1)
if rs:
    m = rs[0]
    print m.get_body()

m.get_body () 自动返回解码结果。有办法检索原始信件吗?

谢谢!

Answer 1

boto.sqs.queue. Quue 的构建者有一个 message_ classle 参数, 您可以设定该参数为 RawMessage 。另一方面, 我不明白为什么在传输该数据之前不编码这些数据是有道理的。

Answer 2

In case you are interested to just read the messages off SQS queue and the producer was someone else, you may start seeing garbage character when call get_messages(). See https://github.com/boto/boto/issues/831

本案中的解决方案再次是:

from boto.sqs.message import RawMessage
q.set_message_class(RawMessage)

Answer 3

Actually Message class inherits from RawMessage, so it has all of it s methods. One of these methods is:

http://boto.s3.amazonaws.com/ref/sqs.html#boto.sqs.message.RawMessage.get_body_encodd@code>get_body_encodd()

This method is really a semi-private method used by the Queue.write method when writing the contents of the message to SQS. You probably shouldn’t need to call this method in the normal course of events.

友情链接