检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
数据转发至第三方应用 转发方式概述 使用HTTP/HTTPS转发 使用AMQP转发 使用MQTT转发 设备间通信 父主题: 规则引擎
s.deviceId}/test/hello。 取值范围:资源列表长度最小为1,最大为10,列表中的资源取值范围:仅支持字母,数字,以及/{}$=+#?*:._-组合。 请求示例 更新设备策略 PUT https://{endpoint}/v5/iot/{project_id}/
使用场景 设备端向自定义Topic发布消息;应用端通过数据转发功能实现数据平滑流转至消息中间件、存储、数据分析、业务应用。 应用端调用下发设备消息接口,向指定的自定义Topic发布消息。设备通过订阅该Topic,接收来自服务端的消息。 端到端通信、广播通信、设备迁移。 使用限制
物联网平台分配获得。 取值范围:长度不超过128,只允许字母、数字、下划线(_)、连接符(-)的组合。 command_id 是 String 参数说明:下发命令的命令id,用于唯一标识一个消息,在下发命令时由物联网平台分配获得。 取值范围:长度不超过100,只允许字母、数字、下划线(_)、连接符(-)的组合。
(C) 原生MQTT/MQTTS协议接入示例 设备侧可以通过原生MQTT/MQTTS协议接入到物联网平台,Demo提供了SSL加密建链和TCP不加密建链、数据上报、订阅Topic的样例代码。 接入示例参考:Java版、Python版、Android版、C版、C#、NodeJS。 quickStart(Java)
参数说明:设备接入MQTTS协议端口, 默认值:8883。 device_https_port Integer 参数说明:设备接入HTTPS协议端口, 默认值:443。 请求示例 创建实例,实例规格标准版中频单元,单元个数为2,计费方式为包年。 POST https://{endpoint}/v5/iot/{
} ] } 设备侧升级包下载指导 设备收到升级通知之后,通过HTTPS协议根据升级通知里面的URL下载升级包。基础版和标准版目前建议客户不校验证书可规避不能下载固件的问题。专享版如果需要校验证书,请提工单,后端帮忙配置域名。 请求方法 下载升级包的请求方法为:GET 请求消息头
数据转发至Kafka存储 场景说明 对于设备上报的数据,可以选择让平台将设备上报数据推送给应用服务器,由应用服务器进行保存;还可以选择让平台将设备上报数据转发给分布式消息服务(Kafka),由Kafka进行存储。 本示例为将所有设备上报的数据转发至Kafka存储。 购买Kafka实例
参数说明:资源空间ID,唯一标识一个资源空间,由物联网平台在创建资源空间时分配。资源空间对应的是物联网平台原有的应用,在物联网平台的含义与应用一致,只是变更了名称。 取值范围:长度不超过36,只允许字母、数字、下划线(_)、连接符(-)的组合。 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token
参数说明:设备组名称,单个资源空间下不可重复。 取值范围:长度不超过64,只允许中文、字母、数字、以及_? '#().,&%@!-等字符的组合。 description 否 String 参数说明:设备组描述。 取值范围:长度不超过64,只允许中文、字母、数字、以及_? '#().
- 物模型Topic通信 √ √ √ - 数据解析转换 √ √ √ - 规则引擎 数据流转 √ √ √ 设备上报数据流转到其他云服务 规则联动 √ √ √ 设备联动规则 SQL数据流转规则 x √ √ 支持对数据先通过类SQL语句进行预处理 HTTP/AMQP订阅推送 √ √ √ -
数据转发至OBS长期存储 场景说明 对于设备上报的数据,可以选择让平台将设备上报数据推送给应用服务器,由应用服务器进行保存;还可以选择让平台将设备上报数据转发给对象存储服务(OBS),由OBS进行存储。 本示例为将所有设备上报的数据转发至OBS存储。 创建OBS桶 登录华为云官方网站,访问对象存储服务。
deviceId}/test/hello。 取值范围:资源列表长度最小为1,最大为10,列表中的资源取值范围:仅支持字母,数字,以及/{}$=+#?*:._-组合。 请求示例 创建设备策略-允许设备订阅与发布指定topic POST https://{endpoint}/v5/iot/{pro
id。 取值范围:长度不超过128,只允许字母、数字、下划线(_)、连接符(-)的组合。 tag_keys 是 Array of strings 参数说明:指定资源要解绑的标签键列表,标签键列表中各项之间不允许重复,不能填写不存在的标签键值 取值范围:标签键长度不超过64,只允许中文、字母、数字、以及_
描述 device_id 是 String 参数说明:下发属性的设备ID,用于唯一标识一个设备,在注册设备时由物联网平台分配获得。 取值范围:长度不超过128,只允许字母、数字、下划线(_)、连接符(-)的组合。 project_id 是 String 参数说明:项目ID。获取方法请参见
单击“上传固件”,在弹出的页面中有两种上传方式,OBS文件上传和本地文件上传。 图3 上传升级包-OBS文件 图4 上传升级包-本地文件 上传升级包后,填写升级包参数信息,单击“确定”完成升级包上传。 图5 上传升级包-OBS文件参数 图6 上传升级包-本地文件参数 升级包上传完成后会在"固件列表"中显示出来。
如果能够查询到node版本,且版本高于8.0.0则代表安装成功。 代码示例 在本地计算机创建一个JavaScript文件(例:HwIotAmqpClient.js),保存以下示例代码到文件中。参考AMQP客户端接入说明修改相关连接参数。 const container = require('rhea');
配置测试事件,调试函数。 创建并配置测试事件,调试函数,如下图所示。 控制台开发 登录设备发放控制台。 进入“证书”界面,上传并验证设备CA证书。 如何上传并验证证书参见证书 。 图1 证书列表 进入“策略”界面,添加自定义策略。 如何添加自定义策略实例参见添加自定义策略实例。 图2 添加自定义策略
订阅/发布消息:设备对云服务端进行主题发布或订阅。 策略鉴权:云服务端根据设备订阅/发布的Topic进行过滤,当该设备订阅的Topic被策略禁止,则响应失败ACK,订阅失败。若允许或未设定,则响应成功ACK,订阅成功。 设备侧发布成功的消息数据可通过数据流转推送到应用侧。 操作步骤
event_time 可选 String 参数解释: 事件时间。UTC时间,格式:yyyyMMdd'T'HHmmss'Z'。 设备上报数据不带该参数或参数格式错误时,则数据上报时间以平台时间为准。 paras 必选 Object 参数解释: 事件参数JSON对象。 paras参数列表 字段名 必选/可选