应用使能 ROMA

处理消息 功能介绍 对收到的通知消息进行确认，可以在指定的时间范围内选择何时进行处理。 调用方法 请参见如何调用API。 URI POST /v1/{project_id}/service/messages 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是

查看更多 →

规则引擎 配置数据转发规则 导入导出规则 父主题： 设备集成指导

查看更多 →

规则引擎 创建规则 查询规则 批量删除规则 调试规则 删除规则 查询规则详情 修改规则 添加目标数据源 查询目标数据源列表 删除目标数据源 添加源数据源 查询源数据源列表 删除源数据源 父主题： 设备集成API

查看更多 →

规则引擎 创建规则引擎源端 创建规则引擎目的端 父主题： 设备集成API（V1）

查看更多 →

规则引擎 规则引擎介绍 数据转发流程 SQL语句 连通性测试 数据转发至华为云服务 数据转发至第三方应用 查看数据转发通道详情 数据转发积压策略配置 数据转发流控策略配置 设备联动

查看更多 →

的端不能收到设备发送的消息。 您可以通过添加入方向规则解决这个问题。如果业务场景需要规则引擎接收特定设备发送的信息，您可以添加入方向规则，将“端口范围”限定为特定设备的端口。如果业务场景需要规则引擎接收所有设备发送的信息，您可以添加入方向规则，将“端口范围”设置为“全部”。 可能是topic被删除。

查看更多 →

被称为堆积消息。消息没有被及时消费就会产生消息堆积，从而会造成消息消费延迟。 消息堆积原因 导致消息堆积的常见原因如下： 生产者短时间内生产大量消息到Topic，消费者无法及时消费。 消费者的消费能力不足（消费者并发低、消息处理时间长），导致消费效率低于生产效率。 消费者异常（如

查看更多 →

消息堆积处理建议 方案概述 在RocketMQ的实际业务中，消息堆积是比较常见的问题。在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息没有被及时消费而产生消息堆积，从而会造成消息消费延迟。对于消息消费实时性要求

查看更多 →

处理企业账号消息 运营人员能够对已经发布的帖子进行维护，主要包括查看帖子点赞数、评论数，以及回复他人评论。 前提条件 租户管理员已在“ > 企业账号运营”中发布了YouTube视频、Facebook帖子。 运营人员为当前租户下的员工并且具备社交媒体和企业账号运营的菜单权限。 背景信息

查看更多 →

处理多媒体消息 前提条件 发帖人@了公共主页，并且发布渠道分配了运营人员。 运营人员为当前租户下的员工并且具备社交媒体和离线消息处理的菜单权限。 背景信息 当前仅支持处理Facebook消息。 运营人员点开消息就视为已处理，页面操作只有通过链接前往帖子，刷新列表后已处理的消息不在页面中展示。

查看更多 →

规则引擎介绍 规则引擎是指用户可以在物联网平台上对接入平台的设备设定相应的规则，在条件满足所设定的规则后，平台会触发相应的动作来满足用户需求。包含设备联动和数据转发两种类型。 设备联动 设备联动指通过条件触发，基于预设的规则，引发多设备的协同反应，实现设备联动、智能控制。目前物联

查看更多 →

可以发送、分享IM消息 请求参数 参数 类型 必填 说明 receiver String 是 联系人id/群组id receiveType String 是 聊天类型：0 单聊 1 群组。默认单聊 cardType String 是 卡片类型：image-txt，暂仅支持 image-txt

查看更多 →

当无法确认消息是否已发送成功，生产者需要将消息重复发送给分布式消息服务Kafka版。 当重复收到已处理过的消息，消费者需要告诉分布式消息服务Kafka版消费成功且保证不重复处理。 消息可以批量生产和消费 为提高消息发送和消息消费效率，推荐使用批量消息发送和消费。 图1 消息批量生产（发送）与消费 图2 消息逐条生产（发送）与消费

查看更多 →

is_base64 boolean 是 转发的消息是否要进行base64编码，传入true会对消息进行base64编码。 contain_deviceinfo boolean 否 转发的消息是否要包含设备的信息，传入true会在原始消息的基础上增加额外设备的信息。 请求示例 https://example

查看更多 →

设备集成 设备集成支持哪些通信协议？ 为什么我的设备不能接入设备集成？ 为什么规则引擎的数据目的端未收到设备发送的消息？

查看更多 →

MRS 可以做什么？ 问： MapReduce Service（MRS）可以做什么？ 答： MapReduce服务 （MapReduce Service）为客户提供ClickHouse、Spark、Flink、Kafka、HBase等Hadoop生态的高性能大数据引擎，支持 数据湖 、数

查看更多 →

负载通道还可以实现后端服务访问的负载均衡功能。 生产者 生产者为向消息主题（Topic）发布消息的一方，发布消息的最终目的在于将消息内容传递给其他系统，使对方能按照约定处理该消息。 消费者 消费者为从消息主题（Topic）订阅消息的一方，订阅消息的最终目的在于处理消息内容。如日志

查看更多 →

消息路由是什么？ 将指定消息从源端点转发到目的端点的转发路径。 目前支持如下几种消息转发路径： SystemREST到Service Bus：通过调用云端的REST Gateway接口，获取边缘节点上的文件服务。需配合边缘市场中的边缘文件服务应用一起使用。 SystemREST到

查看更多 →

什么是云消息服务 KooMessage 是提供数字化营销新入口，覆盖全行业、全场景、全终端的一站式富媒体消息服务。KooMessage融合多种客户触达渠道，包括智能信息、智能信息基础版（视频短信）、服务号、Push消息、媒体投放、一体化智能营销发送等能力，为行业客户提供一站式行业服

查看更多 →

图3 推送详情-数据转发规则 表1 参数说明 参数名称 描述 消息推送速率 物联网平台每秒往转发目标推送消息数量。 消息生产速率 设备侧每秒往物联网平台生产的消息数量。 消息积压量 当生产速率大于推送速率时，积压在物联网的消息数量。物联网平台默认配置单个转发规则流转数据的最大积压（缓

查看更多 →

同时保证消息发送的实时性。 图2 消息逐条生产与消费 此外，批量消费消息时，消费者应按照接收的顺序对消息进行处理、确认，当对某一条消息处理失败时，不再需要继续处理本批消息中的后续消息，直接对已正确处理的消息进行确认即可。 巧用消费组协助运维 用户使用ROMA Connect作为消

查看更多 →