如何用Python解析SQS JSON消息

pip install boto3

import boto3
import json

sqs = boto3.client('sqs', region_name='your_region')

queue_url = 'your_queue_url'

response = sqs.receive_message(
    QueueUrl=queue_url,
    MaxNumberOfMessages=1,
    VisibilityTimeout=0,
    WaitTimeSeconds=0
)

if 'Messages' in response:
    message = response['Messages'][0]
    receipt_handle = message['ReceiptHandle']
    body = json.loads(message['Body'])
    # 处理JSON消息
    # 可以访问body中的数据，例如body['key']
    # ...

    # 删除已处理的消息
    sqs.delete_message(
        QueueUrl=queue_url,
        ReceiptHandle=receipt_handle
    )
else:
    print("No messages in the queue")