检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
购买Kafka实例 登录华为云官方网站，访问分布式消息服务。 单击“进入控制台”进入分布式消息服务管理控制台。 单击右上角“购买Kafka实例”，根据需求选择实例规格与配置安全组后，单击“立即购买”。
托管部署 IoT平台提供泛协议镜像托管部署能力，使用泛协议SDK开发的插件可以制作成镜像托管部署在平台，IoT平台支持对托管的镜像进行分布式自动部署。省去客户自己购买ECS服务器、购买ELB负载均衡、进行容器化等操作和费用。
购买RocketMQ 登录华为云，访问分布式消息服务RocketMQ版， 进入分布式消息服务管理控制台。 单击右上角“购买RocketMQ实例”，按照需求选择RocketMQ规格，单击“立即购买”。
图6 分布式光伏业务架构图 分布式光伏场景参考架构如下： 端侧不同的厂家的逆变器设备通过MQTT协议上报电压，电流，功率，发电量等数据到云端。 云端IoTDA通过规则引擎将数据流转到OBS存储，并经过DLI-Flink处理后写入DWS，便于后续数据治理。
核心知识点：产品模型、编辑码插件、设备影子、属性上报、属性修改。 最佳实践参考：预置设备影子自动调节空调温度。
支持区域： 全部 告警管理 消息跟踪 支持通过消息跟踪功能进行核心业务流程的快速故障定位和原因分析，核心业务场景包括：设备鉴权、设备告警、设备状态变更、命令下发、数据上报、平台数据转发等。支持NB-IoT设备和MQTT设备的消息跟踪，单个用户下，可支持同时进行跟踪的10个设备。
分布式消息服务（Kafka） 说明： 如果选择分布式消息服务，目前只支持转发到Kafka专享版。并且需要开启“kafka自动创建Topic”功能。 区域：选择转发服务的所在区域，若未授权访问此区域的服务，请根据界面提示，配置云服务访问授权。
支持配置异常数据转发的正常转发目标类型：数据接入服务（DIS）、分布式消息服务（Kafka）、对象存储服务（OBS）、应用与数据集成平台（ROMA Connect）、第三方应用服务（HTTP推送）、分布式消息服务（RocketMQ）、函数工作流服务 （FunctionGraph）、
安装Python SDK 执行如下命令安装华为云Python SDK核心库以及相关服务库 # 安装核心库 pip install huaweicloudsdkcore # 安装IoTDA服务库 pip install huaweicloudsdkiotda 代码示例 以调用查询设备列表接口为例
表2 参数说明 参数名 参数说明 转发目标 选择“分布式消息服务（Kafka）” 区域 选择“分布式消息服务”区域。 对接地址 选择kafka服务的对接地址。 主题 填写接收推送消息的kafka topic。
向导式体验智慧烟感接入平台 场景说明 如果您没有IoT设备，但想快速体验设备数据采集和接收控制命令，可以用Windows或者Linux个人计算机作为虚拟设备，体验设备与云端的双向通信。本文以一款虚拟的智慧烟感器为例，带您快速体验平台的三个基本功能：设备连接平台，设备上报数据到平台，
如果状态为PENDING和ERROR，一般来说是网络问题，需要从基站和核心网侧进行分析。 NB模组发送的AT+NMGS数据是否能够被正常解析？ 使用编解码插件检查工具，检测自己准备发送的码流是否可被正常解析。 NB模组无法正常上报数据怎么办？
图6 性能测试 JMeter测试计划调试正常后，可以将测试计划导入到华为云的CodeArts PerfTest服务，进行分布式部署以满足更高规格的性能测试 。 查看压测结果 登录管理控制台，在左侧导航栏“监控运维”->“统计报表”，查看平台的统计指标。
√ √ √ - RocketMQ分布式消息服务 x √ √ - ROMA Connect应用与数据集成平台 x x √ - FunctionGraph函数工作流服务 x √ √ - MRS Kafka流式集群 x x √ - MySQL数据库 x √ √ - InfluxDB时序数据库
支持转发至“数据接入服务DIS”、“分布式消息服务 Kafka”、“对象存储服务 OBS”、“应用与数据集成平台 ROMA Connect”、“第三方应用服务（HTTP推送）”、“AMQP推送消息队列”、、、。
IoT边缘 IoT边缘作为物联网边缘“小脑”，在靠近物或数据源头的边缘侧，融合网络、计算、存储、应用核心能力的开放平台，就近提供计算和智能服务，满足行业在实时业务、应用智能、安全与隐私保护等方面的基本需求。
核心代码参考： try { MessageConsumer consumer = amqpClient.newConsumer(AmqpConstants.DEFAULT_QUEUE); consumer.setMessageListener(message -
边缘节点 是物联网的边缘“小脑”，在靠近物或数据源头的边缘侧，融合网络、计算、存储、应用核心能力的开放平台，就近提供计算和智能服务，满足行业在实时业务、应用智能、安全与隐私保护等方面的基本需求。
代码目录简述： src：源码目录 mqtt_c_demo：demo核心源码； util/string_util.c：工具资源文件； conf：证书目录 rootcert.pem：设备校验平台身份的证书，用于设备侧接入物联网平台登录鉴权使用； include: 头文件目录 base目录
代码目录简述： src：源码目录 mqtt_c_demo：demo核心源码； util/string_util.c：工具资源文件； conf：证书目录 rootcert.pem：设备校验平台身份的证书，用于设备侧接入物联网平台登录鉴权使用；如果对接的IoTDA版本非基础版，请将该证书文件中
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
