Skip to content

Instantly share code, notes, and snippets.

@jayzeng

jayzeng/sqs.py

Created May 22, 2015 18:05
Show Gist options
  • Save jayzeng/4de42d0ba5e580b975b5 to your computer and use it in GitHub Desktop.
Save jayzeng/4de42d0ba5e580b975b5 to your computer and use it in GitHub Desktop.
Download ZIP
boto sqs hello world
Raw
sqs.py
import boto
import json
from boto.sqs.message import Message
sqs = boto.connect_sqs()
queue = sqs.get_queue('queue')
mess = {
"test":"hello world"
}
m = Message()
m.set_body(json.dumps(mess))
queue.write(m)
@jayzeng
Copy link
Author

jayzeng commented May 22, 2015 

queued_messages = queue.get_messages(10)

for qm in queued_messages:
    message_body = json.loads(qm.get_body())
    print message_body
    qm.delete()

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment