Consume SQS

consume.py

# -*- coding: utf-8 -*-
from __future__ import print_function
from __future__ import unicode_literals
from __future__ import division

import sys
import boto.sqs

conn = boto.sqs.connect_to_region('us-east-1')
q = conn.get_queue('foo')

while True:
    message = q.read()
    if not message:
        continue
    print(message.get_body())
    sys.stdout.flush()
    q.delete_message(message)