AWS IoT数据平面

接入教程

1. 在AWS控制台创建IoT策略和证书
2. 为设备配置证书和策略关联
3. 使用AWS SDK连接IoT数据平面端点
4. 通过MQTT或HTTP协议发布测试消息
5. 订阅主题接收设备消息
6. 监控CloudWatch日志验证通信状态

使用Python发布设备影子状态

python

import boto3
from botocore.config import Config

# 配置客户端
client = boto3.client(
    'iot-data',
    endpoint_url='https://data.iot.us-east-1.amazonaws.com',
    region_name='us-east-1',
    aws_access_key_id='YOUR_API_KEY',
    aws_secret_access_key='YOUR_SECRET_KEY'
)

# 更新设备影子
response = client.update_thing_shadow(
    thingName='MyIoTDevice',
    payload=b'{"state": {"desired": {"temperature": 25}}}'
)
print(f"Shadow update response: {response['payload'].read()}")

使用PHP获取设备影子

php

<?php
require 'vendor/autoload.php';

use Aws\IotDataPlane\IotDataPlaneClient;
use Aws\Exception\AwsException;

// 创建客户端
$client = new IotDataPlaneClient([
    'version' => 'latest',
    'region' => 'us-east-1',
    'endpoint' => 'https://data.iot.us-east-1.amazonaws.com',
    'credentials' => [
        'key' => 'YOUR_API_KEY',
        'secret' => 'YOUR_SECRET_KEY'
    ]
]);

// 获取设备影子
try {
    $result = $client->getThingShadow([
        'thingName' => 'MyIoTDevice'
    ]);
    echo "Shadow state: " . $result['payload'] . "\n";
} catch (AwsException $e) {
    echo "Error: " . $e->getMessage() . "\n";
}
?>

使用JavaScript发布MQTT消息

javascript

const AWS = require('aws-sdk');
const iotdata = new AWS.IotData({
  endpoint: 'https://data.iot.us-east-1.amazonaws.com',
  region: 'us-east-1',
  accessKeyId: 'YOUR_API_KEY',
  secretAccessKey: 'YOUR_SECRET_KEY'
});

// 发布消息到主题
const params = {
  topic: 'devices/MyIoTDevice/sensor',
  payload: JSON.stringify({ temperature: 22.5, humidity: 65 }),
  qos: 1
};

iotdata.publish(params, (err, data) => {
  if (err) console.error('Publish error:', err);
  else console.log('Message published successfully:', data);
});

常见问题

AWS IoT数据平面是什么？

AWS IoT数据平面是一项托管服务，提供物联网设备与AWS云之间的安全双向通信。它包含消息代理和设备影子等功能，允许设备发布和订阅消息，并同步设备状态。

如何安全地访问AWS IoT数据平面API？

访问API通常使用AWS签名版本4进行身份验证。您需要在AWS IAM中创建具有iotdata: Publish、iotdata: UpdateThingShadow等权限的用户或角色，并使用其访问密钥和秘密密钥进行API调用。

设备影子有什么作用？

设备影子是一个JSON文档，用于存储和检索设备的当前状态和期望状态。即使设备离线，应用程序也可以更新期望状态，设备重新连接后会同步这些状态变化，确保状态一致性。