通过 AWS IoT Core 实现 IoT 设备连接 - MQTT 通信与设备影子
通过 MQTT 协议连接 IoT 设备，使用设备影子同步状态。介绍规则引擎的数据路由和设备认证设计。
IoT Core 概述
IoT Core 是安全连接数十亿 IoT 设备到云端、每秒处理数百万消息的托管服务。支持 MQTT (v3.1.1 和 v5.0)、HTTPS、MQTT over WebSocket 三种协议，提供设备与云之间的双向消息传递。MQTT 是轻量级的发布/订阅协议，适合带宽受限的设备和不稳定的网络环境。支持 QoS 0 (最多一次) 和 QoS 1 (至少一次)，QoS 1 保证消息到达确认。与自建 MQTT 代理 (Mosquitto、HiveMQ) 相比，设备认证基础设施设计、消息路由实现以及数百万台设备的扩展均为完全托管。
设备影子与规则引擎
设备影子以 JSON 文档管理设备状态。检测 desired (期望状态) 和 reported (实际状态) 的差异作为 delta，通知设备配置变更。设备离线时，下次连接时发送 delta。Named Shadow 允许为一个设备分配多个影子，按功能独立管理状态 (例如固件版本影子和传感器设置影子)。规则引擎使用类 SQL 查询过滤接收消息，将匹配条件的消息路由到 Lambda、DynamoDB、S3、Kinesis、Timestream、IoT Analytics、SNS、SQS 等 20 多个操作目标。可在同一主题上设置多条规则，实现单条消息同时转发到多个服务的扇出。通过与 Kinesis Data Streams 和 Kinesis Data Firehose 的集成，可构建实时聚合大量设备数据并输送到分析平台的流式管道。
设备认证与安全
IoT Core 以 X.509 证书相互 TLS 认证为标准，为每个设备颁发唯一证书。通过 AWS IoT CA 管理证书，可构建 Just-in-Time Registration (JITR) 首次连接时自动注册的机制。IoT 策略按设备单位控制 MQTT 主题的发布/订阅权限，使用 ${iot:Connection.Thing.ThingName} 变量限制设备对特定主题的访问。Device Defender 检测异常连接模式 (大量消息发送、来自未知 IP 的连接)，可自动吊销设备证书。 有关 MQTT 架构模式的理解，可参阅Amazon 的相关书籍。
设备集群管理与 OTA 更新
大规模 IoT 部署需要高效管理数千到数百万台设备的机制。AWS IoT Device Management 提供设备分组、搜索和批量操作。可按标签或自定义属性对设备分组，在组级别应用策略和执行作业。IoT Jobs 安全地向设备交付远程操作 (固件更新、配置变更、重启)。通过滚动部署、指数级推出速率和中止条件，可对大规模集群进行分阶段安全更新。结合 FreeRTOS OTA 库，可自动化向微控制器设备的固件交付。Fleet Provisioning 使用预置模板为出厂设备自动创建 Thing、证书和策略，实现大量设备初始设置的自动化。
使用场景与架构模式
遥测采集: 传感器设备通过 MQTT 定期发送温度、湿度、振动数据，规则引擎存储到 Timestream 并通过 Grafana 可视化。控制消息发送频率和数据量，合理设计发送间隔。远程命令: 从云端向设备发送配置变更或固件更新时，有更新设备影子 desired 状态 (设备接收 delta) 的异步模式和使用预留主题 ($aws/things/{thingName}/jobs) 的 IoT Jobs 模式。IoT Jobs 支持向设备组批量分发、推出速度控制和超时设置。结合 AWS Greengrass，可在边缘设备上运行本地推理和规则引擎，网络断连时设备也能自主运行。IoT SiteWise 专门用于工业设备的资产建模和数据采集，制造业产线监控适合 IoT Core + IoT SiteWise 组合。
费用体系与限制注意事项
IoT Core 的费用由连接时间 (每 100 万分钟 0.08 美元)、消息传递 (每 100 万条消息 1 美元，5KB 单位) 和规则引擎操作执行 (每 100 万次 0.15 美元) 构成。设备影子更新每 100 万次操作 1.25 美元。将消息大小控制在 5KB 以内可优化消息费用。数千台设备每分钟发送消息的环境中成本会急剧增加，因此在边缘进行数据聚合和过滤以减少消息数量的设计非常重要。Basic Ingest (直接发布到预留主题 $aws/rules/{ruleName}) 绕过消息代理直接将数据发送到规则引擎，无需消息传递费用。连接数上限默认为每账户 50 万并发连接，可通过限制提升请求增加。每秒发布请求数也有区域限制，大规模部署前请确认 Service Quotas。
总结
IoT Core 是提供基于 MQTT 的设备连接、X.509 证书认证和规则引擎数据路由的 IoT 平台。通过设备影子管理离线设备状态，通过 Device Defender 检测安全异常，构建安全的 IoT 环境。IoT Device Management 和 IoT Jobs 提供大规模集群管理和 OTA 更新的分阶段交付，覆盖设备的整个生命周期。Basic Ingest 降低消息费用，Fleet Provisioning 实现大量设备初始设置自动化，从而以低成本运营可扩展的 IoT 系统。