检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用设备SDK进行消息收发 概述 华为云IoTDA服务多种语言SDK，通过SDK设备可以快速连接华为云IoTDA并进行消息上下行通信，本文基于Java示例代码演示设备通过MQTTS/MQTT协议接入华为云IoTDA服务并通过Topic发布和订阅消息。 图1 SDK与IoTDA的消息交互流程
否则会影响后续云服务的开通。 已开通设备接入服务。未开通则访问设备接入服务，单击“免费试用”或单击“价格计算器”购买并开通该服务。 已开通Kafka服务。未开通则访问Kafka服务，单击“立即购买”后开通该服务。 已开通数据湖探索服务。未开通则访问数据湖探索服务，单击“立即购买”后开通该服务。
转发给文档数据库服务（DDS），由DDS进行存储（华为云DDS完全兼容MongoDB协议），用户无需做额外的数据存储代码开发即可使用设备数据进行业务处理。本示例为将流转数据转发至文档数据库服务存储。 购买MongoDB实例 登录华为云官方网站，访问文档数据库服务DDS。 单击“进
批量任务的文件管理 上传批量任务文件 查询批量任务文件列表 删除批量任务文件 父主题： 批量任务
ntent、event_time字段。 图1 创建数据库表样例 配置设备接入服务 在设备接入服务中创建产品模型、注册设备并设置数据转发规则，实现当设备上报数据时将数据转发至MySQL。 访问设备接入服务，单击“管理控制台”进入设备接入控制台。选择您的实例，单击实例卡片进入。 选择
信息后，可以使用该安全隧道信息建立与物联网平台的WebSocket连接，用户可以在应用端远程登录使用基于安全隧道建链的设备（远程SSH登录服务），进行设备的更新配置、排查诊断、运维变更等操作。 Topic 下行：$oc/devices/{device_id}/sys/events/down
流转功能将数据转发到应用侧或华为云其他云服务的一种方式。平台对设备上报的消息不进行解析和存储，不需要建立产品模型便可以使用。 图1 设备消息上报流程 使用场景 平台对设备上报的数据不进行解析和存储，需要通过数据转发规则转发到华为云其他云服务上进行存储和处理的场景。 使用限制 单个消息内容不大于1M。
设备异步命令状态变更通知 功能介绍 应用服务器在调用物联网平台的创建规则触发条件（Resource:device.command.status，Event:update）、创建规则动作、修改规则触发条件接口配置并激活规则后，当命令状态变更时，物联网平台会向应用服务器推送通知消息。 URI POST
如果在“设备详情”页面没有最新上报数据，请修改产品模型中服务和属性的内容，确保设备上报的服务/属性和产品模型中的服务/属性一致（如果不一致，则历史数据中看不到设备上报的数据），或者进入“产品 > 基本信息”页面，删除所有服务。 命令下发 在控制台界面单击左侧菜单栏的“API检索和调试”。
AccessPointPara accessPointPara = determineAccessPoint(para); // 发放设备 result = provisionDevice(para, accessPointPara);
功能介绍 应用服务器在调用物联网平台的创建规则触发条件（Resource:device，Event:create）、创建规则动作、修改规则触发条件接口配置并激活规则后，当物联网平台中的设备添加时，物联网平台会向应用服务器推送通知消息。 URI POST /由应用服务器创建设备添加通知规则的转发目标决定
def access_key(self): return self.__access_key @access_key.setter def access_key(self, access_key): self.__access_key
功能介绍 应用服务器在调用物联网平台的创建规则触发条件（Resource:device，Event:update）、创建规则动作、修改规则触发条件接口配置并激活规则后，当物联网平台中的设备更新时，物联网平台会向应用服务器推送通知消息。 URI POST /由应用服务器创建设备更新通知规则的转发目标决定
host self.port = port self.accessKey = accessKey self.accessCode = accessCode self.queueName = queueName
对于设备上报的数据，可以选择让平台将设备上报数据推送给应用服务器，由应用服务器进行保存；还可以选择让平台将设备上报数据转发给分布式消息服务（Kafka），由Kafka进行存储。 本示例为将所有设备上报的数据转发至Kafka存储。 购买Kafka实例 登录华为云官方网站，访问分布式消息服务。 单击“进入控制台”进入分布式消息服务管理控制台。
用户可调用此接口删除关联OBS对象的升级包信息，不会删除OBS上对象 使用前提：使用该API需要您授权设备接入服务(IoTDA)的实例访问对象存储服务(OBS)以及 密钥管理服务(KMS Administrator)的权限。在“统一身份认证服务（IAM） - 委托”中将委托名称为iotda_admin_trust的委托授权KMS
登录华为云，访问对象存储服务OBS，进入对象存储服务管理控制台。 单击“创建桶”，按照需求选择桶规格，单击“立即创建”。 单击“桶列表”，单击进入刚刚创建的桶，单击“新建文件夹”，完成OBS桶创建。 登录华为云官方网站，访问数据接入服务DIS。 单击“管理控制台”进入数据接入服务管理控制台。
单击左侧导航栏“topic管理”，单击“创建topic”创建RocketMQ的topic。 配置设备接入服务 在设备接入服务中设置数据转发规则，实现当设备上报数据时将数据转发至RocketMQ。 访问设备接入服务，单击“立即使用”进入设备接入控制台。 在左侧导航栏选择“规则>数据转发”，单击左上角的“创建规则”。
平台返回access_token。调用属性上报、消息上报等其他接口时，都需要携带access_token信息。如果access_token超期，需要重新认证设备获取access_token。如果access_token未超期重复获取access_token，老的access_to
报数据推送给应用服务器，由应用服务器进行保存；还可以选择让平台将设备上报数据转发给对象存储服务（OBS），由OBS进行存储。 本示例为将所有设备上报的数据转发至OBS存储。 创建OBS桶 登录华为云官方网站，访问对象存储服务。 单击“进入控制台”进入对象存储服务管理控制台。 单击
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
