检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
topic_messages 队列消息总数 统计队列当前的消息总数。 ≥0 单位:个 队列 1分钟 produced_messages 生产消息数 统计目前生产的消息总数。 ≥0 单位:个 队列 1分钟 partition_messages 分区消息数 统计分区中当前的消息个数。 ≥0 单位:个
更新网关子设备状态 主题Topic Topic /v1/devices/{gatewayId}/topo/update 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer 命令ID。 deviceStatuses 必选
节点类型;0-直连,1-网关,2-子设备,不传默认查询所有。 最小值:0 最大值:10 online_status 否 String 是否在线;0-未连接,1-在线,2-离线,支持传入多个值以逗号分隔。 最小长度:0 最大长度:10 created_date_start 否 Long 创建时
设备命令下发 主题Topic Topic /v1/devices/{gatewayId}/command 消息发送方 物联网平台 消息接收方 边设备 参数说明 字段名 必选/可选 类型 参数描述 deviceId 必选 String 平台生成的设备唯一标识,对应设备客户端ID。 msgType
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 id
Connect实例控制台的“设备集成 LINK > 设备管理”页面中,可以看到设备的“状态”为“在线”。 设备上报车位状态数据。 当车位状态变化时,车位感应设备上报车位状态数据。 在ROMA Connect实例控制台选择“消息集成MQS > 消息查询”,选择配置设备数据转发MQS中所创建的Topic,可看到转发到MQS的设备数据记录。
acks=0:表示producer不需要等待任何确认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败),回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待lead
SDK概述 本文介绍了ROMA Connect服务提供的SDK语言版本,列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 在开始使用之前,请确保您安装的是最新版本的SDK
消息集成开发指导 开发说明 开发准备 MQS连接开发(开源客户端) MQS连接开发(RESTful API)
接入数据源 概述 在创建数据API之前,您需要先接入数据源,确保可以正常从数据源读取数据。根据数据源类型的不同,数据源的接入配置有所差异。 前提条件 在接入数据源前,请确保ROMA Connect实例与您的数据源所在网络互通。 若ROMA Connect实例与数据源在相同VPC内时,可直接访问数据源。
设备数据上报 主题Topic Topic /v1/devices/{gatewayId}/datas 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 devices 必选 DeviceS[] 设备数据。 DeviceS结构体说明 字段名 必选/可选
添加网关子设备 主题Topic Topic /v1/devices/{gatewayId}/topo/add 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer 命令ID。 deviceInfos 必选 List<DeviceInfos>
填写连接器的描述信息,用于识别不同的连接器。 支持的动作 写入消息 配置参数 表1 发送消息 参数 说明 主题 填写需要监听的topic。 Partition 消息将被写入的分区。 Key 消息Key值。 Message 消息内容。 Acks 发送确认参数。 all -1 0 1 KeySerializer
Topic Topic即消息主题,是消息队列的一种发布与订阅消息的模型,消息的生产、消费及管理围绕着消息主题进行。生产者向消息主题发布消息,多个消费者订阅该消息主题的消息,生产者与消费者彼此并无直接关系。 产品 产品是某一类具有相同能力或特征的设备合集。每个设备都有一个归属的产品,通过定义产品来确定设备所具备的功能属性。
消费消息接口说明 功能介绍 消费指定队列中的消息,可同时消费多条消息。 当队列中消息较少时,单次消费返回的消息数量可能会少于指定条数,但多次消费最终可获取全部消息。当返回的消息为空数组时,表示未消费到消息。 endpoint为https://{rest_connect_addre
在新增的请求参数中,“参数名”填写“x-auth”,“参数值”填写“user1:xxxx”。 图4 API调试 单击URL右侧的“调试”,页面下方显示调用API发送的请求信息和接收的响应结果信息。 此时,响应结果中显示调用API成功的响应信息“ROMA TEST!”。 HTTP/1.1 200 OK Transfer-Encoding:
开发说明 开发场景 开发规范 客户端使用建议 客户端参数配置建议 父主题: 消息集成开发指导
hmac(string value, string secret, string algorithm) 使用提供的值、密钥和散列函数算法生成基于散列的消息验证码。必须是HmacSHA1、HmacSHA256或HmacSHA512中的一种。 encrypt(string value, string secret
发布的环境编号 remark String 发布描述 publish_time String 发布时间 version_id String 在线的版本号 状态码: 400 表5 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String
用户在编辑设计组合应用时,可以通过变量的方式快速引用流任务中的输入输出信息和配置信息,帮助用户便捷高效的设计组合应用。 在线调试 创建组合应用和工作流并配置完成后,可对工作流进行在线调试,实时查看各个节点的运行信息,便于后续对工作流进行调整以满足业务需求。 监控统计 提供组合应用运行记录、系统日志、运行监控等监控信息统计。