aws sqs dead letter queue sample(w/ boto)

create_dlq.py

# vim: set fileencoding=utf8
# http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/SQSDeadLetterQueue.html
# http://aws.typepad.com/aws/2014/01/amazon-sqs-new-dead-letter-queue.html

import json
import boto
from pprint import pprint

conn = boto.connect_sqs()
q1  = conn.create_queue('test_q1')
q2  = conn.create_queue('test_q2')
dlq = conn.create_queue('test_dlq')
policy = {
  "maxReceiveCount" : 5,
  "deadLetterTargetArn": dlq.arn
}

policy = json.dumps(policy)

q1.set_attribute('RedrivePolicy', policy)
print 'queue attributes for', q1.name
pprint(q1.get_attributes())

q2.set_attribute('RedrivePolicy', policy)
print 'queue attributes for', q2.name
pprint(q2.get_attributes())

print 'dead letter source queues for', dlq.name
pprint(conn.get_dead_letter_source_queues(dlq))