Extract SQS Queue Message in Lambda Function

Question

I have an SQS queue which triggers my Lambda function. I am trying to parse the SQS message and extract relevant data. I am specifically trying to extract the s3 object key and the s3 bucket arn.

My current Lambda function:

def lambda_handler(event, context):
       
    for record in event['Records']:
        payload = record['body']
        print(str(payload))

        objectKey = record['body']['s3']['object']['key']
        bucketARN = record['body']['s3']['bucket']['arn']
        
        print('Filename is: ' + str(objectKey))
        print('Bucket ARN is: ' + str(bucketARN))

My SQS message that is shown in CloudWatch:

{
    "Records": [
        {
            "eventVersion": "2.1",
            "eventSource": "aws:s3",
            "awsRegion": "xxx",
            "eventTime": "2021-03-27T19:39:41.694Z",
            "eventName": "ObjectCreated:Put",
            "userIdentity": {
                "principalId": "AWS:AIDAQ5MMP4GQL2S4KQ2SZ"
            },
            "requestParameters": {
                "sourceIPAddress": "xxx"
            },
            "responseElements": {
                "x-amz-request-id": "xxx",
                "x-amz-id-2": "xxx"
            },
            "s3": {
                "s3SchemaVersion": "1.0",
                "configurationId": "xxx",
                "bucket": {
                    "name": "xxx",
                    "ownerIdentity": {
                        "principalId": "AHWVPEVW911DW"
                    },
                    "arn": "arn:aws:s3:::xxx"
                },
                "object": {
                    "key": "Audio1.mp3",
                    "size": 16659,
                    "eTag": "71d5ea0a7152e04d0d170be8146080ba",
                    "sequencer": "00605F8A02147F848A"
                }
            }
        }
    ]
}

And lastly the error I'm being given:

[ERROR] TypeError: string indices must be integers
Traceback (most recent call last):
  File "/var/task/transcribe.py", line 14, in lambda_handler
    objectKey = record['body']['s3']['object']['key']

I have also tried objectKey = record['Records][0]['s3']['object']['key']. Thanks.

Wouldn't it just be record['s3']['object']['key']? You can debug via print(record) and see what it contains. — John Rotenstein
– John Rotenstein, Commented Mar 28, 2021 at 2:43
You might want to use: objectKey = urllib.parse.unquote_plus(record['s3']['object']['key'])) — John Rotenstein
– John Rotenstein, Commented Mar 28, 2021 at 2:45

Jamie · Accepted Answer · 2021-03-28 10:27:48Z

0

Found a helpful answer to a similar question here.

This worked for me:

for record in event['Records']:     
        #pull the body out & json load it
        jsonmaybe = record['body']
        jsonmaybe = json.loads(jsonmaybe)
        
        objectKey = jsonmaybe['Records'][0]['s3']['object']['key']
        print(objectKey)
        bucketARN = jsonmaybe['Records'][0]['s3']['bucket']['arn']
        print(bucketARN)

answered Mar 28, 2021 at 10:27

Jamie

1554 silver badges14 bronze badges

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

Collectives™ on Stack Overflow

Extract SQS Queue Message in Lambda Function

1 Answer 1

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related