Skip to content

Instantly share code, notes, and snippets.

@Jamie-BitFlight
Forked from philchristensen/sqs.py
Created February 1, 2017 13:24
Show Gist options
  • Save Jamie-BitFlight/11a43059a790c0cb16ccb7ba961ddfa8 to your computer and use it in GitHub Desktop.
Save Jamie-BitFlight/11a43059a790c0cb16ccb7ba961ddfa8 to your computer and use it in GitHub Desktop.
Minimal script for sending/reading from Amazon SQS using Boto/Python.
conf = {
"sqs-access-key": "",
"sqs-secret-key": "",
"sqs-queue-name": "",
"sqs-region": "us-east-1",
"sqs-path": "sqssend"
}
import boto.sqs
conn = boto.sqs.connect_to_region(
conf.get('sqs-region'),
aws_access_key_id = conf.get('sqs-access-key'),
aws_secret_access_key = conf.get('sqs-secret-key')
)
q = conn.create_queue(conf.get('sqs-queue-name'))
from boto.sqs.message import RawMessage
m = RawMessage()
m.set_body('Reader started at this point.')
retval = q.write(m)
print 'added message, got retval: %s' % retval
import time
while(True):
for m in q.get_messages():
print '%s: %s' % (m, m.get_body())
q.delete_message(m)
time.sleep(1)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment