检查 AWS IoT 核心规则和 DynamoDB 表设置以确保正确配置。还应检查 AWS IoT 设备是否发送完整的消息负载,以及在处理接收到的消息负载时是否存在任何错误。以下是一个可能的解决方法的代码示例,可用于 AWS Lambda 中:
import boto3
import json
dynamodb = boto3.resource('dynamodb')
table_name = 'my_table'
def lambda_handler(event, context):
for record in event['Records']:
try:
# 解析接收到的消息
payload = json.loads(record['payload'])
# 向DynamoDB表插入数据
table = dynamodb.Table(table_name)
table.put_item(Item=payload)
except Exception as e:
print(e)
return 'Success'
请注意,此示例仅用于演示,需要根据具体情况进行修改和优化。