检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
GO Demo使用说明 本文以Go语言为例,介绍应用通过MQTTS协议接入平台,接收服务端订阅消息的示例。 前提条件 熟悉Go语言开发环境配置,熟悉Go语言基本语法。 开发环境 本示例使用了Go 1.18版本。 添加依赖 本示例使用的Go语言的Mqtt依赖为paho.mqtt.golang(本示例使用版本为v1
参数说明:设备命令所属的设备服务ID,在设备关联的产品模型中定义。 buffer_timeout Integer 参数说明:设备命令的缓存时间,单位为秒,表示物联网平台在把命令下发给设备前缓存命令的有效时间,超过这个时间后命令将不再下发,默认值为172800s(48小时)。 如果buffer_timeo
离线开发产品模型 概述 产品模型本质上就是一个devicetype-capability.json文件和若干个serviceType-capability.json文件,其中devicetype-capability.json是描述产品模型包含的服务能力的文件,serviceType-capability
代码开发 准备工作 开发环境要求:已经安装JDK(版本1.8.以上)和maven。 已下载泛协议SDK和样例。 项目结构说明 项目结构说明 图1 项目结构图 表1 类相关说明 类名称 描述 Main 主启动类。 BridgeService 网桥初始化:初始化同IoT平台的连接,设置平台下行数据监听
字段只可填写一个。 ttl 否 Integer 参数说明:下发消息在平台缓存的老化时间,时间单位是分钟,默认值1440;ttl参数数值必须是5的倍数,即以5分钟为粒度;指定为0时表示不缓存消息,默认最大缓存时间为1440分钟。 表4 PropertiesDTO 参数 是否必选 参数类型
查询数据流转流控策略列表 功能介绍 应用服务器可调用此接口查询在物联网平台设置的数据流转流控策略列表。 调用方法 请参见如何调用API。 URI GET /v5/iot/{project_id}/routing-rule/flowcontrol-policy 表1 路径参数 参数
重置设备指纹 功能介绍 应用服务器可调用此接口重置设备指纹。携带指定设备指纹时将之重置为指定值;不携带时将之置空,后续设备第一次接入时,该设备指纹的值将设置为第一次接入时的证书指纹。 调用方法 请参见如何调用API。 URI POST /v5/iot/{project_id}/d
参数说明:设备命令所属的设备服务ID,在设备关联的产品模型中定义。 buffer_timeout Integer 参数说明:设备命令的缓存时间,单位为秒,表示物联网平台在把命令下发给设备前缓存命令的有效时间,超过这个时间后命令将不再下发,默认值为172800s(48小时)。 如果buffer_timeo
在线开发产品模型 概述 在线开发产品模型前需要创建产品。创建产品需要输入产品名称、协议类型、数据格式、所属行业和设备类型等信息,产品模型会使用这些信息作为设备能力字段取值。物联网平台提供了标准模型和厂商模型,这些模型涉及多个领域,模型中提供了已经编辑好的产品模型文件,您可以根据自
Java SDK接入示例 本文介绍使用AMQP协议的JMS客户端接入华为云物联网平台,接收服务端订阅消息的示例。 开发环境要求 本示例使用的开发环境为JDK 1.8及以上版本。 获取SDK AMQP SDK为开源SDK。如果您使用Java开发语言,推荐使用Apache Qpid JMS客户端。请访问Qpid
来调整Jmeter发起的吞吐量。 图6 性能测试 JMeter测试计划调试正常后,可以将测试计划导入到华为云的CodeArts PerfTest服务,进行分布式部署以满足更高规格的性能测试 。 查看压测结果 登录管理控制台,在左侧导航栏“监控运维”->“统计报表”,查看平台的统计指标。 图7 统计报表-查看统计报表
产品模型,在物联网平台构建一款设备的抽象模型。详情请参见什么是产品模型。 消息下发 消息下发不依赖产品模型,提供给设备的单向通知,具有消息缓存功能;详情请参见消息下发概述。 命令下发 为能有效地对设备进行管理,设备的产品模型中定义了物联网平台可向设备下发的命令,应用服务器可以调用
还有消息。hasMore字段仅在PSM模式下生效,当上报数据的hasMore字段为1时,物联网平台暂时不下发缓存命令,直到收到hasMore字段为0的上报数据,才下发缓存命令。如上报数据不携带hasMore字段,则物联网平台按照hasMore字段为0处理。 data ArrayNode
发送通知”、“上报告警”、“恢复告警”。 数据转发:包含设置转发数据、设置转发目标和启动规则三部分。支持转发至“数据接入服务DIS”、“分布式消息服务 Kafka”、“对象存储服务 OBS”、“应用与数据集成平台 ROMA Connect”、“第三方应用服务(HTTP推送)”、“AMQP推送消息队列”、、、。
使用设备SDK进行消息收发 概述 华为云IoTDA服务多种语言SDK,通过SDK设备可以快速连接华为云IoTDA并进行消息上下行通信,本文基于Java示例代码演示设备通过MQTTS/MQTT协议接入华为云IoTDA服务并通过Topic发布和订阅消息。 图1 SDK与IoTDA的消息交互流程
S,DMS(Kafka),VPCEP 等,FullAccess中缺少对应权限,需单独添加; 更多相关功能需要的权限,请参见表1所示。 由于缓存的存在,对用户、用户组授予IoTDA相关的角色后,大概需要等待15分钟角色才能生效;授予IoTDA相关的策略后,大概需要等待5分钟策略才能生效。
属性下发 概述 属性下发分为查询设备属性和修改属性参数两种,查询设备属性用于应用侧或平台主动获取设备属性数据,修改属性参数用于应用侧或平台设置设备属性值并同步到设备侧。设备接收到属性下发指令后需要立即响应,如果设备没有响应,平台会认为属性下发执行超时。 使用场景 用于平台主动获取或修改设备属性值。
参数说明:设备命令所属的设备服务ID,在设备关联的产品模型中定义。 buffer_timeout 否 Integer 参数说明:设备命令的缓存时间,单位为秒,表示物联网平台在把命令下发给设备前缓存命令的有效时间,超过这个时间后命令将不再下发,默认值为172800s(48小时)。 如果buffer_timeo
status String 消息状态,包含PENDING,DELIVERED,FAILED和TIMEOUT,PENDING指设备不在线,消息被缓存起来,等设备上线之后下发; DELIVERED指消息发送成功;FAILED消息发送失败;TIMEOUT指消息在平台默认时间内(1天)还没有
status String 消息状态,包含PENDING,DELIVERED,FAILED和TIMEOUT,PENDING指设备不在线,消息被缓存起来,等设备上线之后下发; DELIVERED指消息发送成功;FAILED消息发送失败;TIMEOUT指消息在平台默认时间内(1天)还没有