Using Boto3 to process SQS messages

process_sqs_messages.py

    import boto3
    # Get the service resource
    sqs = boto3.resource('sqs')

    # Get the queue. This returns an SQS.Queue instance
    queue = sqs.get_queue_by_name(QueueName='my-queue')

    # You can now access identifiers and attributes
    logger.info(queue.url)

    # Process messages
    for message in queue.receive_messages(VisibilityTimeout=8000, MaxNumberOfMessages=10):

        # Print out the body and author (if set)
        payload = json.loads(message.body)

        for key in payload.keys():
            print('{0} = {1}'.format(key, payload[key]))

        # Let the queue know that the message is processed
        message.delete()