CODEWITHSUNDEEP
botomessageamazon-sqs
user4279562
user4279562

Reputation: 669

boto.sqs: read and write SQS messages

I would like to read messages from one que and write them to another que. But, the message class is custom format and I am not sure how to write a message class and import it.

That is, the structure follows as:

import boto.sqs

#read messages from one que
conn = boto.sqs.connect_to_region("regionName")
q=conn.get_queue('queueName')
res=q.get_messages()
m = res[0].get_body() #This is the message I read 

#Now, I want to write the message into another que
r = conn.get_queue('DifferentqueueName')
r.write(m)

Here, the code breaks and I get the following error messages:

224         new_msg = self.connection.send_message(self,
--> 225             message.get_body_encoded(), delay_seconds=delay_seconds,
226             message_attributes=message.message_attributes)
227         message.id = new_msg.id

AttributeError: 'unicode' object has no attribute 'get_body_encoded'

How can define a custom message class and use it to write to another que? Or, if I could just inherit the class when reading messages and use it for writing, that would be even easier. Can I do any of these?

Thank you.

Upvotes: 0

Views: 1956

Answers (2)

Tal Joffe
Tal Joffe

Reputation: 5828

garnaat's code was problemetic for me (I'm reading the queue with the Java SDK maybe that is the reason) so I used a slight veriation on it:

import boto.sqs
from boto.sqs.message import RawMessage

conn = boto.sqs.connect_to_region("avilability_zone")
q1 = conn.get_queue('original_queue')
q2 = conn.get_queue('new_queue')

for i in range(1,400):
    messages = q1.get_messages(10)
    for message in messages:
        msg_body = message.get_body()
        new_msg = RawMessage()
        new_msg.set_body(msg_body)
        q2.write(new_msg)
        q1.delete_message(message)
    print("{}/400".format(i))

Upvotes: 1

garnaat
garnaat

Reputation: 45846

The reason you are getting the error is because you are attempting to write a raw string to the queue rather than a Message object. Try this, instead:

import boto.sqs

#read messages from one que
conn = boto.sqs.connect_to_region("regionName")
q1 = conn.get_queue('queueName')
q2 = conn.get_queue('DifferentqueueName')
messages = q1.get_messages()
for message in messages:
    msg_body = message.get_body() #This is the message I read
    # Now, I want to write the message into another queue       
    new_msg = q2.new_message(msg_body)
    q2.write(new_msg)

Upvotes: 1

Related Questions