检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
l API,并对外开放。 消息集成:创建消息Topic,不同系统通过Topic进行对接,发送和接收消息。 设备集成:在云端定义设备模型和注册设备,设备通过集成SDK接入云端,发送和接收消息。
提供了可靠的异步消息传递机制,允许不同的应用程序之间通过消息进行通信。它采用了基于消息的中间件模式,允许生产者(发送者)将消息发送到队列或主题,而消费者(接收者)则可以从队列或主题中接收并处理这些消息。 创建ArtemisMQ连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。
提供了可靠的异步消息传递机制,允许不同的应用程序之间通过消息进行通信。它采用了基于消息的中间件模式,允许生产者(发送者)将消息发送到队列或主题,而消费者(接收者)则可以从队列或主题中接收并处理这些消息。 创建ArtemisMQ连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。
则,允许规则引擎的数据目的端接收所有设备发送的消息。如果您在没有创建其他入方向规则的情况下删除了这条规则,会让整个安全组缺少入方向规则,导致规则引擎的数据目的端不能收到设备发送的消息。 您可以通过添加入方向规则解决这个问题。如果业务场景需要规则引擎接收特定设备发送的信息,您可以添
IAM认证开发(AK/SK) 使用AK(Access Key ID)、SK(Secret Access Key)对请求进行签名。 AK:访问密钥ID。与私有访问密钥关联的唯一标识符,访问密钥ID和私有访问密钥一起使用,对请求进行加密签名。 SK:与访问密钥ID结合使用的密钥,对请
ELK部署在独立服务器中,ELK的Logstash接收到日志数据后,根据设置的过滤解析规则,对日志数据进行拆分和过滤,然后将解析后的日志数据发送到ELK的ElasticSearch进行存储。 ELK的ElasticSearch接收到日志数据后,生成日志数据的索引并存储数据,为Ki
查询网关信息 主题Topic Topic /v1/devices/{gatewayId}/topo/query 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer 命令ID。 nodeId 必选 String 设备标识。
每次生产消息,生产者都需要等待消息发送API的应答信号,以确认消息是否成功发送。在消息传递过程中,如果发生异常,生产者没有接收到发送成功的信号,生产者自己决策是否需要重复发送消息。如果接收到发送成功的信号,则表明该消息已经被ROMA Connect可靠存储。 消息消费 消息消费时,消费者需要确认消息是否已被成功消费。
更新网关子设备状态 主题Topic Topic /v1/devices/{gatewayId}/topo/update 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer 命令ID。 deviceStatuses 必选
设备命令下发 主题Topic Topic /v1/devices/{gatewayId}/command 消息发送方 物联网平台 消息接收方 边设备 参数说明 字段名 必选/可选 类型 参数描述 deviceId 必选 String 平台生成的设备唯一标识,对应设备客户端ID。 msgType
参数 说明 事件订阅名称 在事件网格创建的事件订阅名称。 区域 事件网格服务所在区域。 项目 事件网格服务所在项目。 通道 事件通道,存储接收到的事件消息,并根据事件规则将事件消息路由到事件目标。 事件源 华为云服务事件源。 事件类型 华为云服务的事件类型,用于生成过滤规则。 过滤规则
acks=0:表示producer不需要等待任何确认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败),回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待lead
设备数据上报 主题Topic Topic /v1/devices/{gatewayId}/datas 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 devices 必选 DeviceS[] 设备数据。 DeviceS结构体说明 字段名 必选/可选
最小长度:0 最大长度:200 request_id String 消息ID。 最小长度:0 最大长度:64 请求示例 修改指定订阅配置,把接收通知的Topic改为指定Topic。 { "topic" : "Topic1", "status" : 0 } 响应示例 状态码:
在新增的请求参数中,“参数名”填写“x-auth”,“参数值”填写“user1:xxxx”。 图4 API调试 单击URL右侧的“调试”,页面下方显示调用API发送的请求信息和接收的响应结果信息。 此时,响应结果中显示调用API成功的响应信息“ROMA TEST!”。 HTTP/1.1 200 OK Transfer-Encoding:
APP认证工作原理 APP认证流程 构造规范请求。 将待发送的请求内容按照与APIC后台约定的规则组装,确保客户端签名、APIC后台认证时使用的请求内容一致。 使用规范请求和其他信息创建待签字符串。 使用AK/SK和待签字符串计算签名。 将生成的签名信息作为请求消息头添加到HTT
删除网关子设备 主题Topic Topic /v1/devices/{gatewayId}/topo/delete 消息发送方 物联网平台 消息接收方 边设备 参数说明 字段名 必选/可选 类型 参数描述 id 必选 Integer 删除子设备命令ID。 deviceId 必选 String
添加网关子设备 主题Topic Topic /v1/devices/{gatewayId}/topo/add 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer 命令ID。 deviceInfos 必选 List<DeviceInfos>
504(数据写入结束) 505(写任务强制取消) 506(在writer plugin中,任务发生了中断) 507(写任务恢复运行) 900(接收到调度请求) 901(任务运行结束) 902(任务已运行结束,正在进行数据完整性校验) 903(输出数据完整性校验结果) 904(经过数据
ATH和QUERY位置,通过参数映射,后端服务将在HEADER位置接收test01和test03的值。test02在API请求中的HEADER位置,通过参数映射,后端服务将在PATH位置以参数名test05来接收test02的值。 入参名称 入参位置 后端参数名称 后端参数位置 test01