Download messages from SQS Queue

download-messages.py

import json
import boto3


# Get the service resource
sqs = boto3.resource(
    'sqs',
    aws_access_key_id='your_key',
    aws_secret_access_key='your_access_key',
    region_name='your_aws_region'
)

# Get the queue
queue = sqs.get_queue_by_name(QueueName='queue_name')

all_messages = []
message_count = 0

# Total messages on queue
messages_quantity = 5
while messages_quantity > message_count:
    for message in queue.receive_messages(MaxNumberOfMessages=10):
        body = json.loads(message.body)
        all_messages.append(body)
        message_count += 1
        if message_count > messages_quantity:
            break

# Save messages downloaded to ./messages directory
for message in all_messages:
    filename = './messages/{}.json'.format(message['MessageId'])
    with open(filename, 'w') as fp:
        fp.write(json.dumps(message, sort_keys=True, indent=4, ensure_ascii=False))

print('Downloaded {} messages.'.format(len(all_messages)))