How to Parse SQS JSON Message with Python

Question

I have been trying to wrap my head around this, but I can't seem to get it to work. I can drill down into 'Messages' by specifying it in the sqs polling, but can't get deeper in:

I am retrieving an AWS SQS message:

import boto3

sqs = boto3.client('sqs',
                   aws_access_key_id='<aws-id>',
                   aws_secret_access_key='<aws-key>',
                   region_name='<aws-region>'
                   )

queue_url = '<aws-queue-url'
# Long poll for message on provided SQS queue
response = sqs.receive_message(
    QueueUrl=queue_url,
    MaxNumberOfMessages=1,
    MessageAttributeNames=[
        'Messages'
    ],
    WaitTimeSeconds=20
)

Which returns a JSON response:

{
  'Messages': [
    {
      'MessageId': '37b13967-a92e-4b8b-8aef-32341a8e1e32',
      'ReceiptHandle': 'xyz',
      'MD5OfBody': '081f4bdad6fd3d53c88f165a884a39da',
      'Body': '{"inputIDList":["1234","5678"],"eventID":"9337","scheduleEvent":false,"addToList":true,"listID":"7654","clientID":"123-ABC-456"}'
    }
  ],
  'ResponseMetadata': {
    'RequestId': '79dafe96-04d9-5122-8b2a-a89b79a76a46',
    'HTTPStatusCode': 200,
    'HTTPHeaders': {
      'x-amzn-requestid': '79dafe96-04d9-5122-8b2a-a89b79a76a46',
      'date': 'Tue, 01 Oct 2019 16:13:50 GMT',
      'content-type': 'text/xml',
      'content-length': '4792'
    },
    'RetryAttempts': 0
  }
}

All I need to do here is extract the value for 'Body', but I can't quite drill down far enough without erroring out.

What I would like to return is essentially just this as JSON or a string:

'{"inputIDList":["1234","5678"],"eventID":"9337","scheduleEvent":false,"addToList":true,"listID":"7654","clientID":"123-ABC-456"}'

I'm extremely new at this. Any help would be greatly appreciated!

matesio · Accepted Answer · 2019-10-01 20:27:05Z

7

You can get the required output using

print (response['Messages'][0]['Body'])

answered Oct 1, 2019 at 20:27

matesio

1,60218 silver badges32 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

marc_s · Accepted Answer · 2023-02-26 15:04:52Z

2

In addition to @matesio answer, if you want to store the body of the message as a python dictionary just wrap it with json.loads:

import json
message = json.loads(response['Messages'][0]['Body'])

edited Feb 26, 2023 at 15:04

marc_s

760k186 gold badges1.4k silver badges1.5k bronze badges

answered Feb 12, 2021 at 13:58

Alex Lopez

211 bronze badge

Collectives™ on Stack Overflow

How to Parse SQS JSON Message with Python

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related