亚马逊网络服务IoT和SQS :在亚马逊网络服务中重定向到SQS时如何获取IoT主题和完成JSON有效负载

import boto3

# 创建SQS客户端
sqs_client = boto3.client('sqs')

# 接收消息
response = sqs_client.receive_message(
    QueueUrl='SQS队列的URL',
    MaxNumberOfMessages=1,
    WaitTimeSeconds=10
)

# 解析消息
if 'Messages' in response:
    message = response['Messages'][0]
    body = message['Body']
    # 获取IoT主题
    iot_topic = message['MessageAttributes']['iot_topic']['StringValue']
    # 获取JSON有效负载
    json_payload = message['MessageAttributes']['json_payload']['StringValue']
    # 处理消息
    # ...

# 删除已接收的消息
sqs_client.delete_message(
    QueueUrl='SQS队列的URL',
    ReceiptHandle=message['ReceiptHandle']
)