Python AWS Lambda 事件 JSON

Question

我正在尝试解析 AWS Lambda 的事件数据，我已将它连接到 SQS，并且我正在使用 SQS 发送 JSON 格式。

这是我的 AWS Lambda 函数

import json

def lambda_handler(event, context):
    # print(event)
    # print(event['Records'][0])
    x = event['Records'][0]['body']
    print(x)
    print(type(x))

以下是事件数据

{
   "Records":[
      {
         "messageId":"916f5e95-b2f6-4148-9c62-2ac8e764f06c",
         "receiptHandle":"AQEBmLuoGWtLtFFgvyCFdSPMJh2HKgHOIPWNUq22EOwCzGT8iILZm97CE6j4J6oR71ZpDr3sgxQcJyVZ+dmmvGl+fFftT9GCJqZYrjMGsR2Q6WsMd8ciI8bTtDXyvsk8ektd7UGfh4gxIZoFp7WUKVRcMEeBkubKd8T4/Io81D0l/AK7MxcEfCj40vWEsex1kkGmMRlBtdSeGyy7fJgUq5CFAYWciiWtbSit8S0Y38xZPmsIFhoxP0egQRoJcW4aUgMi469Gj5+khizetybtgC8vux5NCg/IejxcCueXkQ7LKVF8kfRdqRSUYB6DsOrGgfmZpK4wpXIarByNz0R2p7J88meYpj2IVULv/emXsSYaKG4rXnpbH4J9ijbLWckYLAd7wPDzCYri1ZSTgAz0kchsEw==",
         "body":"{\n\"name\": \"aniket\",\n\"tag\": \"hello\"\n}",
         "attributes":{
            "ApproximateReceiveCount":"1",
            "SentTimestamp":"1602046897707",
            "SenderId":"AIDAR3BXDV4FCWXL56NUU",
            "ApproximateFirstReceiveTimestamp":"1602046897712"
         },
         "messageAttributes":{
            
         },
         "md5OfBody":"98da683a47692b39c1d43bd4fa21ed89",
         "eventSource":"aws:sqs",
         "eventSourceARN":"arn:aws:sqs:ap-south-1:126817120010:documentation",
         "awsRegion":"ap-south-1"
      }
   ]
}
    

我正在尝试访问数据主体。

这就是我想要的

"{\n\"name\": \"aniket\",\n\"tag\": \"hello\"\n}"

它的类型是字符串。

我需要做什么才能将其转换为正确的 JSON 格式？

我还尝试了以下方法:

import json

def lambda_handler(event, context):
    data = json.dumps(event['Records'][0]['body'])
    print(data)

这是输出

"{\n\"name\": \"aniket\",\n\"tag\": \"hello\"\n}"

但这次的类型是 JSON。

预期的格式是

{
"name": "aniket",
"tag": "hello"
}

Answer 1

您必须使用 json.loads 而不是 json.dumps。

试试这个:

import json

event = {
   "Records":[
      {
         "messageId":"916f5e95-b2f6-4148-9c62-2ac8e764f06c",
         "receiptHandle":"AQEBmLuoGWtLtFFgvyCFdSPMJh2HKgHOIPWNUq22EOwCzGT8iILZm97CE6j4J6oR71ZpDr3sgxQcJyVZ+dmmvGl+fFftT9GCJqZYrjMGsR2Q6WsMd8ciI8bTtDXyvsk8ektd7UGfh4gxIZoFp7WUKVRcMEeBkubKd8T4/Io81D0l/AK7MxcEfCj40vWEsex1kkGmMRlBtdSeGyy7fJgUq5CFAYWciiWtbSit8S0Y38xZPmsIFhoxP0egQRoJcW4aUgMi469Gj5+khizetybtgC8vux5NCg/IejxcCueXkQ7LKVF8kfRdqRSUYB6DsOrGgfmZpK4wpXIarByNz0R2p7J88meYpj2IVULv/emXsSYaKG4rXnpbH4J9ijbLWckYLAd7wPDzCYri1ZSTgAz0kchsEw==",
         "body":"{\n\"name\": \"aniket\",\n\"tag\": \"hello\"\n}",
         "attributes":{
            "ApproximateReceiveCount":"1",
            "SentTimestamp":"1602046897707",
            "SenderId":"AIDAR3BXDV4FCWXL56NUU",
            "ApproximateFirstReceiveTimestamp":"1602046897712"
         },
         "messageAttributes":{

         },
         "md5OfBody":"98da683a47692b39c1d43bd4fa21ed89",
         "eventSource":"aws:sqs",
         "eventSourceARN":"arn:aws:sqs:ap-south-1:126817120010:documentation",
         "awsRegion":"ap-south-1"
      }
   ]
}

parsed = json.loads(event['Records'][0]['body'])
print(json.dumps(parsed, indent=4, sort_keys=True))

输出:

{
    "name": "aniket",
    "tag": "hello"
}