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