FMQ 消息推送
理解规则与连接器的分工，完成 RabbitMQ 推送并确认外部队列实收。
阅读方法
先确认入口、权限和目标对象，再按编号完成操作。每一步都包含预期结果；详细字段和选项收在可展开的参考表中。
截图说明
截图来自原始操作手册。公开版会隐藏真实节点地址、连接地址和凭据；示例中的状态、时间和数据不代表当前生产环境。
开始前准备
| 项目 | 说明 |
|---|---|
| 能做什么 | 理解规则与连接器的分工，完成 RabbitMQ 推送并确认外部队列实收。 |
| 从哪里进入 | 集成 → 消息推送 |
| 需要权限 | 任务管理、连接器使用权限及获准的外部测试资源。 |
| 预计时间 | 45 分钟 |
消息推送概述
消息推送是 FMQ 把已经进入平台的设备事件，按规则筛选后发送给外部业务系统的功能。它解决的是“哪些事件需要送出去、送到哪里、怎么确认真的送达”，不是用来配置设备怎样接入 FMQ。
例如温度传感器每次上报都会形成属性事件。规则只让 temperature 大于等于 30 的事件通过，推送动作再借助 RabbitMQ 连接器把标准 Alink 消息发给告警系统。25℃不会发送，31.5℃会发送。
- 只有外部系统需要消费设备事件时才创建消息推送任务。
- 连接器可以被多条任务复用；每条任务仍有自己的事件、SQL 和目标动作参数。
- 完成标志不是“保存成功”，而是能指出消息在规则、动作、本地队列、Broker 或外部队列中的哪一级。
组成、边界与选择
消息推送任务把一次完整出站行为组织在一起；事件规则回答“什么时候触发”；推送动作回答“发到哪个 Topic、Exchange 或 URL”；连接器保存可复用的 Broker 地址、认证和连接参数。
启用和停用只控制实时事件是否自动触发。详情里的“真实推送”是人工验证入口，即使任务停用也会主动发送；使用它之前必须确认目标是获准的测试资源。
已有连接器类型正确、最近检查通过且归属明确时优先复用。需要独立认证、独立 Broker 或隔离故障影响时才在任务内新建；外部 MQTT Broker 尤其应先在连接器模块完成校验。
任务组成与选择
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 必填 任务名称 | 让实施人员能从列表识别用途。名称不要只写MQ类型。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 由任务负责人按业务用途命名。 | 本例填温度告警推送，并区分测试与生产。推荐：按对接资料填写默认：—示例：FastBee_温度告警推送 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 任务描述 | 补充触发条件和接收方；当前保存接口使用描述作为规则名称，单独填写不同描述可能改变列表显示名称。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 任务负责人。 | 本例留空；保存后回详情核对名称。推荐：按对接资料填写默认：—示例：留空 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 启用状态 | 开启后参与实时事件匹配；关闭后不自动触发，但人工真实推送仍能发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 按当前调试或上线阶段选择。 | 新建默认可能开启，本例必须手动关闭，闭环验证后再开启。推荐：按对接资料填写默认：—示例：停用启用：处理实时事件；命中就自动触发停用：不处理实时事件；人工真实推送仍有副作用 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 必填 触发事件 | 选择要监听的事件类别，不是直接选择设备Topic。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 从设备业务行为判断。 | 测温数据选属性上报，上下线分别选客户端连接或断开。推荐：按对接资料填写默认：—示例：属性上报属性上报：设备上报温度、湿度、电量等当前属性时触发。；遥测转发、阈值告警、数据同步。事件上报：设备主动上报告警或业务事件时触发，可继续按 eventCode 筛选。；告警中心、工单系统、审计通知。设备状态变化：设备或协议通道的业务状态发生变化时触发，不等同于 MQTT 客户端上下线。；运行状态同步、通道异常通知。客户端连接：MQTT 客户端成功连接并进入在线状态时触发。；在线通知、登录审计、连接趋势分析。客户端断开：MQTT 客户端正常断开、超时或网络中断后离线时触发。；离线告警、连接质量分析。死信消息：下行或转发链路无法继续处理消息并转入死信时触发。；失败归档、人工补偿、异常统计。回复消息：设备对下行命令或服务调用返回处理结果时触发。；命令回执同步、调用结果归档。 | 切换事件会更新字段选择和SQL，已有条件要重新核对。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 必填 推送目标 | 选择接收方实际使用的消息服务。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接收系统管理员提供的对接方案。 | 以对方现有协议为准，不按图标或熟悉程度选择。推荐：按对接资料填写默认：—示例：RabbitMQKafka：对方已有 Kafka，且需要高吞吐、可回放的流式消费时使用。；显示该类型的连接器和动作字段。RabbitMQ：需要清晰交换机、路由键和队列绑定关系，或对方以业务队列消费时使用。；显示该类型的连接器和动作字段。RocketMQ：对方使用 RocketMQ，并通过 Topic 与 Tag 组织消息时使用。；显示该类型的连接器和动作字段。WebHook：对方只提供 HTTP 接口，且能承受事件到来时的同步请求时使用。真实推送会真正调用该接口。；显示该类型的连接器和动作字段。MQTT：对方以 MQTT Topic 订阅数据时使用；外部 Broker 优先复用连接器模块中已校验的外部连接器。；显示该类型的连接器和动作字段。 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器来源 | 复用使用已有连接；新建会建立一份连接配置。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 现有连接器清单和业务隔离要求。 | 优先复用已经校验且环境正确的连接器；需要新地址或独立认证时另建。推荐：按对接资料填写默认：—示例：优先使用已有连接器复用现有连接器：使用已保存连接资源；不覆盖原连接参数任务内新建连接器：输入有限连接字段；保存时创建连接资源；高级参数到连接器模块配置 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 必填 已有连接器 | 按当前目标类型选择具体连接资源。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 连接器列表，支持名称或ID查找。 | 核对目标环境和检查结果；同名不同ID不能混用。推荐：按对接资料填写默认：—示例：FastBee_消息推送连接器 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接名称 | 任务内新建模式下新连接器的名称。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 由对接负责人按环境与用途指定。 | 需要发布确认或外部MQTT连接时优先到连接器模块创建再复用。推荐：按对接资料填写默认：—示例：FastBee_消息推送连接器 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 任务链路预览 | 汇总触发事件、标准Alink内容和发送位置。；用于理解和判断当前结果；不改变任务。 | 当前编辑草稿。 | 只用于核对配置；预览正确并不表示接收方已收到。推荐：按对接资料填写默认：—示例：属性上报 → 标准Alink → RabbitMQ | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 创建任务 / 保存修改 | 分步保存连接器、动作和规则。不是原子的一次业务发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 保持停用保存，返回详情核对引用关系，再检查。推荐：按对接资料填写默认：—示例：创建任务 / 保存修改 | 部分保存失败可能留下已创建连接器或动作；不要连续重复新建。；保持停用保存，返回详情核对引用关系，再检查。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 取消 / 关闭 | 退出当前表单。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 仅修改草稿时取消即可；已提交部分资源需检查列表。推荐：按对接资料填写默认：—示例：取消 / 关闭 | 未保存的修改会丢失。；仅修改草稿时取消即可；已提交部分资源需检查列表。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
RabbitMQ 完整实战
本实战先保持任务停用，按 25℃不命中、31.5℃命中、人工真实推送、监控、队列实收、错误路由恢复的顺序验证；最后才启用任务，用 LinkPilot GUI 发送 32.6℃真实属性事件。
准备资料分三组：FMQ管理员提供可用的RabbitMQ消息推送连接器及权限；RabbitMQ管理员提供AMQP地址、vhost、交换机类型和授权；外部接收方确认Queue及Binding。密码只经受控渠道填写。
本例交换机FastBee_push_7e9c24_exchange采用topic类型，队列FastBee_push_7e9c24_queue以FastBee.push.7e9c24绑定。先确认队列为空且没有其他消费者，再执行测试。发布确认必须在连接器模块显式开启，任务内简化表单不会提供该选项。
先记录发送前计数，再核对每次测试带来的增量。完整实战会产生多条消息，读取并确认上一条之后再开始下一次，不能把历史消息当成本次实收。
1. 进入消息推送列表
操作位置： 集成→消息推送
打开 集成 → 消息推送，先查看现有任务、启用状态和最近结果。
图：消息推送列表显示新建、搜索、筛选和刷新入口。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 搜索 | 按任务身份和页面支持的描述范围定位。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：当前列表中的任务名称等信息。选择：搜不到时先清空条件和状态筛选。推荐：按对接资料填写 · 示例：FastBee_温度告警推送 |
| 状态筛选 | 只显示选定启停状态的任务。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：任务当前状态。选择：排查找不到任务时先切全部。推荐：按对接资料填写 · 示例：全部 |
2. 准备 RabbitMQ 对接资料
操作位置： 集成→消息推送
向 RabbitMQ 管理员取得可用连接器，并确认 Exchange、目标队列和 Routing Key 的绑定关系。
图：RabbitMQ专用队列已绑定到本批次Exchange，Routing Key与对接资料一致，初始无消息。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 连接器来源 | 复用使用已有连接；新建会建立一份连接配置。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：现有连接器清单和业务隔离要求。选择：优先复用已经校验且环境正确的连接器；需要新地址或独立认证时另建。推荐：按对接资料填写 · 示例：优先使用已有连接器 |
| 动作级：Exchange | 这条任务向哪个交换机发布。动作值与连接器默认值分开核对；实战显式填写。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：RabbitMQ管理员提供已声明的交换机和类型。选择：本例使用topic交换机；不能把Queue名称填到这里。交换机为空时存在默认交换机语义，不作为本例配置。推荐：按对接资料填写 · 示例：FastBee_push_7e9c24_exchange |
| 动作级：Routing Key | 匹配交换机与队列的绑定规则，决定消息进入哪个队列。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：队列Binding约定。选择：先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写 · 示例：FastBee.push.7e9c24 |
3. 填写任务名称并保持停用
操作位置： 集成→消息推送
点击 新建推送任务，任务名称填写 FastBee_温度告警推送，先关闭启用开关。
图：新建任务名称已填写，启用开关关闭。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 任务名称 | 让实施人员能从列表识别用途。名称不要只写MQ类型。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：由任务负责人按业务用途命名。选择：本例填温度告警推送，并区分测试与生产。推荐：按对接资料填写 · 示例：FastBee_温度告警推送 |
| 任务描述 | 补充触发条件和接收方；当前保存接口使用描述作为规则名称，单独填写不同描述可能改变列表显示名称。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：任务负责人。选择：本例留空；保存后回详情核对名称。推荐：按对接资料填写 · 示例：留空 |
| 启用状态 | 开启后参与实时事件匹配；关闭后不自动触发，但人工真实推送仍能发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：按当前调试或上线阶段选择。选择：新建默认可能开启，本例必须手动关闭，闭环验证后再开启。推荐：按对接资料填写 · 示例：停用 |
4. 选择属性上报事件
操作位置： 集成→消息推送
在“什么时候触发”中选择 属性上报。
图：已选属性上报，事件源为$events/property_post。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 触发事件 | 选择要监听的事件类别，不是直接选择设备Topic。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：从设备业务行为判断。选择：测温数据选属性上报，上下线分别选客户端连接或断开。推荐：按对接资料填写 · 示例：属性上报 |
5. 填写温度筛选 SQL
操作位置： 集成→消息推送
展开高级筛选，填写手册给出的 SELECT、FROM 和 WHERE，条件为 payloadJson.temperature >= 30。
图：SQL按属性上报事件筛选温度大于等于30的消息。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 已选 / 可选字段 | 选择按钮修改SELECT列表，主要便于生成和阅读SQL。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：所选事件的字段目录。选择：选择关注字段；选择不会删除外发params中的其他属性。推荐：按对接资料填写 · 示例：clientId, deviceKey, protocol, params, timestamp |
| FROM 事件源 | 限制接收哪种事件。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：先选择页面事件，再使用对应事件源。选择：双引号包住事件源，属性上报使用本例值。推荐：按对接资料填写 · 示例：FROM "$events/property_post" |
| 筛选 SQL / WHERE | 决定哪条事件符合发送条件；没有WHERE时该源的事件均可通过。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：业务阈值和真实事件字段。选择：温度用数字31.5，不写带单位的字符串。含边界30，所以本例是达到30℃而不是严格超过30℃。推荐：按对接资料填写 · 示例：SELECT clientId, deviceKey, protocol, params, timestamp FROM "$events/property_post" WHERE payloadJson.temperature >= 30 |
6. 复用已校验的 RabbitMQ 连接器
操作位置： 集成→消息推送
推送目标选择 RabbitMQ，连接器选择“优先使用已有连接器”，选中 FastBee_消息推送连接器。
图：RabbitMQ目标复用专用已校验连接器。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 推送目标 | 选择接收方实际使用的消息服务。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：接收系统管理员提供的对接方案。选择：以对方现有协议为准，不按图标或熟悉程度选择。推荐：按对接资料填写 · 示例：RabbitMQ |
| 连接器来源 | 复用使用已有连接；新建会建立一份连接配置。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：现有连接器清单和业务隔离要求。选择：优先复用已经校验且环境正确的连接器；需要新地址或独立认证时另建。推荐：按对接资料填写 · 示例：优先使用已有连接器 |
| 已有连接器 | 按当前目标类型选择具体连接资源。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：连接器列表，支持名称或ID查找。选择：核对目标环境和检查结果；同名不同ID不能混用。推荐：按对接资料填写 · 示例：FastBee_消息推送连接器 |
7. 填写 Exchange 和 Routing Key
操作位置： 集成→消息推送
Exchange 填 FastBee_push_7e9c24_exchange，Routing Key 填 FastBee.push.7e9c24。
图：任务动作单独填写Exchange和Routing Key，不修改连接器认证。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 动作级：Exchange | 这条任务向哪个交换机发布。动作值与连接器默认值分开核对；实战显式填写。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：RabbitMQ管理员提供已声明的交换机和类型。选择：本例使用topic交换机；不能把Queue名称填到这里。交换机为空时存在默认交换机语义，不作为本例配置。推荐：按对接资料填写 · 示例：FastBee_push_7e9c24_exchange |
| 动作级：Routing Key | 匹配交换机与队列的绑定规则，决定消息进入哪个队列。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：队列Binding约定。选择：先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写 · 示例：FastBee.push.7e9c24 |
8. 创建停用任务
操作位置： 集成→消息推送
点击 创建任务，返回详情后再次确认任务仍为停用。
图：任务已由页面创建并保存，当前停用，详情显示属性事件和RabbitMQ目标。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 启用状态 | 开启后参与实时事件匹配；关闭后不自动触发，但人工真实推送仍能发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：按当前调试或上线阶段选择。选择：新建默认可能开启，本例必须手动关闭，闭环验证后再开启。推荐：按对接资料填写 · 示例：停用 |
9. 用 25℃验证不命中
操作位置： 集成→消息推送
在测试区输入 temperature=25，点击 检查一下。
图：25度检查不命中，不执行真实推送。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 筛选 SQL / WHERE | 决定哪条事件符合发送条件；没有WHERE时该源的事件均可通过。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：业务阈值和真实事件字段。选择：温度用数字31.5，不写带单位的字符串。含边界30，所以本例是达到30℃而不是严格超过30℃。推荐：按对接资料填写 · 示例：SELECT clientId, deviceKey, protocol, params, timestamp FROM "$events/property_post" WHERE payloadJson.temperature >= 30 |
10. 用 31.5℃验证命中
操作位置： 集成→消息推送
把测试温度改为 31.5，再点击 检查一下。
图：31.5度检查命中，生成Alink预览，尚未真实发送。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 筛选 SQL / WHERE | 决定哪条事件符合发送条件；没有WHERE时该源的事件均可通过。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：业务阈值和真实事件字段。选择：温度用数字31.5，不写带单位的字符串。含边界30，所以本例是达到30℃而不是严格超过30℃。推荐：按对接资料填写 · 示例：SELECT clientId, deviceKey, protocol, params, timestamp FROM "$events/property_post" WHERE payloadJson.temperature >= 30 |
11. 停用状态执行真实推送
操作位置： 集成→消息推送
保持任务停用，点击 真实推送 并确认使用当前模拟事件发送。
图：停用任务通过人工真实推送提交了RabbitMQ动作。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 启用状态 | 开启后参与实时事件匹配；关闭后不自动触发，但人工真实推送仍能发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：按当前调试或上线阶段选择。选择：新建默认可能开启，本例必须手动关闭，闭环验证后再开启。推荐：按对接资料填写 · 示例：停用 |
12. 区分动作提交和 Broker 实际成功
操作位置： 集成→消息推送
打开 监控，分别查看提交成功、实际成功、积压、丢弃、队列容量和最近异常。
图：任务监控分别显示提交成功、实际成功、积压和容量。
13. 先核对实收消息的路由与 Alink 外层
操作位置： 集成→消息推送
在获准的 RabbitMQ 管理界面读取 FastBee_push_7e9c24_queue，先核对消息编号、Exchange、Routing Key 以及 Alink 的 id、version、method、sys。
图：RabbitMQ目标队列收到Message 1，Exchange、Routing Key及Alink外层字段正确。
14. 再核对同一条消息的 params
操作位置： 集成→消息推送
保持在刚读取的 Message 1，横向查看 Payload 尾部。
图：同一条Message 1的Payload尾部显示params.temperature=31.5。
15. 把隔离任务改成错误 Routing Key
操作位置： 集成→消息推送
在隔离任务中把 Routing Key 改为 FastBee.push.7e9c24.missing 并保存，再次用31.5℃执行真实推送。
图：当前任务Routing Key填写为 FastBee.push.7e9c24.missing
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 动作级：Routing Key | 匹配交换机与队列的绑定规则，决定消息进入哪个队列。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：队列Binding约定。选择：先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写 · 示例：FastBee.push.7e9c24 |
16. 确认错误路由仍被 Broker 接收
操作位置： 集成→消息推送
执行本次真实推送后打开 监控统计，记录 Broker 实际成功计数。
图：任务监控分别显示提交成功、实际成功、积压和容量。
17. 确认错误路由没有进入目标队列
操作位置： 集成→消息推送
打开 FastBee_push_7e9c24_queue 并展开 Overview，确认 Ready 为 0 且没有其他消费者。
图：错误Routing Key已被Broker确认，但专用队列Ready=0、Unacked=0、Total=0且没有其他消费者。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 动作级：Routing Key | 匹配交换机与队列的绑定规则，决定消息进入哪个队列。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：队列Binding约定。选择：先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写 · 示例：FastBee.push.7e9c24 |
18. 改回正确 Routing Key
操作位置： 集成→消息推送
把 Routing Key 改回 FastBee.push.7e9c24 并保存，再次用31.5℃执行真实推送。
图：当前任务Routing Key填写为 FastBee.push.7e9c24
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 动作级：Routing Key | 匹配交换机与队列的绑定规则，决定消息进入哪个队列。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。必填 · 来源：队列Binding约定。选择：先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写 · 示例：FastBee.push.7e9c24 |
19. 确认恢复后 Broker 再次成功
操作位置： 集成→消息推送
打开监控，确认恢复后的真实推送让提交成功和实际成功再次增加。
图：任务监控分别显示提交成功、实际成功、积压和容量。
20. 确认正确路由恢复外部实收
操作位置： 集成→消息推送
在目标队列读取恢复后新到达的 Message 1，并查看 Payload 尾部。
图：RabbitMQ目标队列本次实收，params.temperature=31.5；确认读取后从专用队列移除。
21. 启用任务
操作位置： 集成→消息推送
返回任务详情点击 启用。
图：任务已启用，准备接收真实设备属性事件。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 启用状态 | 开启后参与实时事件匹配；关闭后不自动触发，但人工真实推送仍能发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：按当前调试或上线阶段选择。选择：新建默认可能开启，本例必须手动关闭，闭环验证后再开启。推荐：按对接资料填写 · 示例：停用 |
22. 用 LinkPilot GUI 发送 32.6℃属性事件
操作位置： 集成→消息推送
在 LinkPilot GUI 建立真实 MQTT 会话，向当前 FMQ 发送设备属性 JSON，temperature=32.6。FMQ 会在上行链路将它组装为标准 Alink。
图：LinkPilot真实MQTT会话发送设备属性JSON，temperature=32.6；FMQ会在上行链路组装标准Alink。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 启用状态 | 开启后参与实时事件匹配；关闭后不自动触发，但人工真实推送仍能发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：按当前调试或上线阶段选择。选择：新建默认可能开启，本例必须手动关闭，闭环验证后再开启。推荐：按对接资料填写 · 示例：停用 |
| 筛选 SQL / WHERE | 决定哪条事件符合发送条件；没有WHERE时该源的事件均可通过。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：业务阈值和真实事件字段。选择：温度用数字31.5，不写带单位的字符串。含边界30，所以本例是达到30℃而不是严格超过30℃。推荐：按对接资料填写 · 示例：SELECT clientId, deviceKey, protocol, params, timestamp FROM "$events/property_post" WHERE payloadJson.temperature >= 30 |
23. 确认真实设备事件触发了推送
操作位置： 集成→消息推送
回到任务详情打开监控，比较 LinkPilot 发送前后的提交成功和 Broker 实际成功计数。
图：任务监控分别显示提交成功、实际成功、积压和容量。
24. 确认自动触发消息再次实收
操作位置： 集成→消息推送
在 RabbitMQ 目标队列读取 LinkPilot 发送后新到达的消息，查看设备 Topic、method 和 params。
图：RabbitMQ目标队列本次实收，params.temperature=32.6；确认读取后从专用队列移除。
七类触发事件与字段参考
页面给出的字段目录说明该事件类型可能提供哪些值，不表示每条消息一定全部非空。设备协议、消息来源和运行阶段不同，都可能让 productId、tenantId、username、ip、reason 或 params 缺失；写 WHERE 前应先用真实样本确认。
属性上报
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 触发时机与来源 | 设备上报温度、湿度、电量等当前属性时触发。；用于理解和判断当前结果；不改变任务。 | 平台事件目录和实际事件分类。 | 遥测转发、阈值告警、数据同步。 示例：温度传感器上报 temperature=31.5。推荐：按对接资料填写默认：—示例：$events/property_post | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 客户端标识（clientId） | 当前事件所属客户端，用于区分发送来源。；用于理解和判断当前结果；不改变任务。 | 会话或标准Alink sys中的客户端标识。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：FastBee_测温 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备ID（deviceId） | 设备主数据标识；无绑定时可能为空，不能要求每条事件都有。；用于理解和判断当前结果；不改变任务。 | 设备绑定信息或Alink sys。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备记录 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备键（deviceKey） | 跨协议定位设备的标识，不一定与客户端ID相同。；用于理解和判断当前结果；不改变任务。 | Alink sys及协议运行上下文。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备键 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 产品ID（productId） | 设备所属产品；没有产品关联的样本可能为空。；用于理解和判断当前结果；不改变任务。 | Alink sys中的产品关联。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际产品 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 租户ID（tenantId） | 消息所属租户；无租户上下文时可能为空。；用于理解和判断当前结果；不改变任务。 | Alink sys中的租户关联。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际租户 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 协议（protocol） | 来源设备使用的协议标识，不是推送目标的MQ类型。；用于理解和判断当前结果；不改变任务。 | 接入适配器或Alink sys。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：MQTT | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 业务参数（params） | 属性值、事件参数或回复结果；对象可以为空。；用于理解和判断当前结果；不改变任务。 | 标准Alink params。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例： | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 消息文本（payloadText） | 消息文本表示；在标准Alink链路中通常是整个Alink JSON，不只是params。；用于理解和判断当前结果；不改变任务。 | 实际消息序列化结果。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：完整Alink JSON | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件时间（timestamp） | 事件上下文时间，通常是毫秒时间戳；不是监控采样时间。；用于理解和判断当前结果；不改变任务。 | sys.ts，缺失时由运行时按实现补充。 | 用于遥测转发、阈值告警、数据同步。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：毫秒时间戳 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
事件上报
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 触发时机与来源 | 设备主动上报告警或业务事件时触发，可继续按 eventCode 筛选。；用于理解和判断当前结果；不改变任务。 | 平台事件目录和实际事件分类。 | 告警中心、工单系统、审计通知。 示例：设备上报 eventCode=alarm 的高温告警。推荐：按对接资料填写默认：—示例：$events/event_post | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 客户端标识（clientId） | 当前事件所属客户端，用于区分发送来源。；用于理解和判断当前结果；不改变任务。 | 会话或标准Alink sys中的客户端标识。 | 用于告警中心、工单系统、审计通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：FastBee_测温 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备键（deviceKey） | 跨协议定位设备的标识，不一定与客户端ID相同。；用于理解和判断当前结果；不改变任务。 | Alink sys及协议运行上下文。 | 用于告警中心、工单系统、审计通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备键 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件编码（eventCode） | 业务事件的类别，用来区分alarm等事件。；用于理解和判断当前结果；不改变任务。 | 由Alink method识别。 | 用于告警中心、工单系统、审计通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：alarm | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 业务参数（params） | 属性值、事件参数或回复结果；对象可以为空。；用于理解和判断当前结果；不改变任务。 | 标准Alink params。 | 用于告警中心、工单系统、审计通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例： | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 消息文本（payloadText） | 消息文本表示；在标准Alink链路中通常是整个Alink JSON，不只是params。；用于理解和判断当前结果；不改变任务。 | 实际消息序列化结果。 | 用于告警中心、工单系统、审计通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：完整Alink JSON | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件时间（timestamp） | 事件上下文时间，通常是毫秒时间戳；不是监控采样时间。；用于理解和判断当前结果；不改变任务。 | sys.ts，缺失时由运行时按实现补充。 | 用于告警中心、工单系统、审计通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：毫秒时间戳 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
设备状态变化
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 触发时机与来源 | 设备或协议通道的业务状态发生变化时触发，不等同于 MQTT 客户端上下线。；用于理解和判断当前结果；不改变任务。 | 平台事件目录和实际事件分类。 | 运行状态同步、通道异常通知。 示例：Modbus 通道从活动状态变为 INACTIVE。推荐：按对接资料填写默认：—示例：$events/device_status_change | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 客户端标识（clientId） | 当前事件所属客户端，用于区分发送来源。；用于理解和判断当前结果；不改变任务。 | 会话或标准Alink sys中的客户端标识。 | 用于运行状态同步、通道异常通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：FastBee_测温 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备键（deviceKey） | 跨协议定位设备的标识，不一定与客户端ID相同。；用于理解和判断当前结果；不改变任务。 | Alink sys及协议运行上下文。 | 用于运行状态同步、通道异常通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备键 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 协议（protocol） | 来源设备使用的协议标识，不是推送目标的MQ类型。；用于理解和判断当前结果；不改变任务。 | 接入适配器或Alink sys。 | 用于运行状态同步、通道异常通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：MQTT | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 状态事件类型（eventType） | 协议通道或设备状态变更的具体类别。；用于理解和判断当前结果；不改变任务。 | 协议适配器生成的扩展字段。 | 用于运行状态同步、通道异常通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：MODBUS_CHANNEL_INACTIVE | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 状态摘要（summary） | 对本次状态变化的简短描述，不宜作为稳定编码使用。；用于理解和判断当前结果；不改变任务。 | 协议运行时生成的扩展信息。 | 用于运行状态同步、通道异常通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：通道不可用 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 状态值（status） | 当前变化后的状态；客户端连接为3，断开为4，其他状态事件可能为文本。；用于理解和判断当前结果；不改变任务。 | 事件分类及Alink sys.ext等扩展信息。 | 用于运行状态同步、通道异常通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：3 / 4 / INACTIVE | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件时间（timestamp） | 事件上下文时间，通常是毫秒时间戳；不是监控采样时间。；用于理解和判断当前结果；不改变任务。 | sys.ts，缺失时由运行时按实现补充。 | 用于运行状态同步、通道异常通知。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：毫秒时间戳 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
客户端连接
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 触发时机与来源 | MQTT 客户端成功连接并进入在线状态时触发。；用于理解和判断当前结果；不改变任务。 | 平台事件目录和实际事件分类。 | 在线通知、登录审计、连接趋势分析。 示例：设备 device-001 从 192.0.2.10 上线。推荐：按对接资料填写默认：—示例：$events/client_connected | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 客户端标识（clientId） | 当前事件所属客户端，用于区分发送来源。；用于理解和判断当前结果；不改变任务。 | 会话或标准Alink sys中的客户端标识。 | 用于在线通知、登录审计、连接趋势分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：FastBee_测温 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备键（deviceKey） | 跨协议定位设备的标识，不一定与客户端ID相同。；用于理解和判断当前结果；不改变任务。 | Alink sys及协议运行上下文。 | 用于在线通知、登录审计、连接趋势分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备键 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接用户名（username） | 来源客户端的身份信息，不是RabbitMQ连接器账号。；用于理解和判断当前结果；不改变任务。 | 客户端会话扩展信息。 | 用于在线通知、登录审计、连接趋势分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：实际设备身份 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 来源IP（ip） | 客户端网络地址；代理、协议和事件来源不同可能缺失。；用于理解和判断当前结果；不改变任务。 | 连接会话或事件扩展。 | 用于在线通知、登录审计、连接趋势分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：192.0.2.10 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 状态值（status） | 当前变化后的状态；客户端连接为3，断开为4，其他状态事件可能为文本。；用于理解和判断当前结果；不改变任务。 | 事件分类及Alink sys.ext等扩展信息。 | 用于在线通知、登录审计、连接趋势分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：3 / 4 / INACTIVE | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 清理会话标志（cleanSession） | 描述客户端连接时的会话选项，不是任务启停开关。；用于理解和判断当前结果；不改变任务。 | MQTT连接事件扩展。 | 用于在线通知、登录审计、连接趋势分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：true | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件时间（timestamp） | 事件上下文时间，通常是毫秒时间戳；不是监控采样时间。；用于理解和判断当前结果；不改变任务。 | sys.ts，缺失时由运行时按实现补充。 | 用于在线通知、登录审计、连接趋势分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：毫秒时间戳 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
客户端断开
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 触发时机与来源 | MQTT 客户端正常断开、超时或网络中断后离线时触发。；用于理解和判断当前结果；不改变任务。 | 平台事件目录和实际事件分类。 | 离线告警、连接质量分析。 示例：设备因 keepalive_timeout 离线。推荐：按对接资料填写默认：—示例：$events/client_disconnected | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 客户端标识（clientId） | 当前事件所属客户端，用于区分发送来源。；用于理解和判断当前结果；不改变任务。 | 会话或标准Alink sys中的客户端标识。 | 用于离线告警、连接质量分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：FastBee_测温 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备键（deviceKey） | 跨协议定位设备的标识，不一定与客户端ID相同。；用于理解和判断当前结果；不改变任务。 | Alink sys及协议运行上下文。 | 用于离线告警、连接质量分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备键 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 原因（reason） | 解释断开或死信产生的原因，并非所有消息都提供。；用于理解和判断当前结果；不改变任务。 | 相应故障或断开事件扩展。 | 用于离线告警、连接质量分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：keepalive_timeout | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 状态值（status） | 当前变化后的状态；客户端连接为3，断开为4，其他状态事件可能为文本。；用于理解和判断当前结果；不改变任务。 | 事件分类及Alink sys.ext等扩展信息。 | 用于离线告警、连接质量分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：3 / 4 / INACTIVE | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 来源IP（ip） | 客户端网络地址；代理、协议和事件来源不同可能缺失。；用于理解和判断当前结果；不改变任务。 | 连接会话或事件扩展。 | 用于离线告警、连接质量分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：192.0.2.10 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件时间（timestamp） | 事件上下文时间，通常是毫秒时间戳；不是监控采样时间。；用于理解和判断当前结果；不改变任务。 | sys.ts，缺失时由运行时按实现补充。 | 用于离线告警、连接质量分析。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：毫秒时间戳 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
死信消息
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 触发时机与来源 | 下行或转发链路无法继续处理消息并转入死信时触发。；用于理解和判断当前结果；不改变任务。 | 平台事件目录和实际事件分类。 | 失败归档、人工补偿、异常统计。 示例：消息因目标不可用进入死信链路。推荐：按对接资料填写默认：—示例：$events/deadletter_post | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 客户端标识（clientId） | 当前事件所属客户端，用于区分发送来源。；用于理解和判断当前结果；不改变任务。 | 会话或标准Alink sys中的客户端标识。 | 用于失败归档、人工补偿、异常统计。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：FastBee_测温 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备键（deviceKey） | 跨协议定位设备的标识，不一定与客户端ID相同。；用于理解和判断当前结果；不改变任务。 | Alink sys及协议运行上下文。 | 用于失败归档、人工补偿、异常统计。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备键 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 来源Topic（topic） | 原始消息所在的主题，不是本任务目标RabbitMQ队列。；用于理解和判断当前结果；不改变任务。 | 事件或Alink sys中的源主题。 | 用于失败归档、人工补偿、异常统计。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：/FastBee_测温/property/post | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 原因（reason） | 解释断开或死信产生的原因，并非所有消息都提供。；用于理解和判断当前结果；不改变任务。 | 相应故障或断开事件扩展。 | 用于失败归档、人工补偿、异常统计。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：keepalive_timeout | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 消息文本（payloadText） | 消息文本表示；在标准Alink链路中通常是整个Alink JSON，不只是params。；用于理解和判断当前结果；不改变任务。 | 实际消息序列化结果。 | 用于失败归档、人工补偿、异常统计。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：完整Alink JSON | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件时间（timestamp） | 事件上下文时间，通常是毫秒时间戳；不是监控采样时间。；用于理解和判断当前结果；不改变任务。 | sys.ts，缺失时由运行时按实现补充。 | 用于失败归档、人工补偿、异常统计。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：毫秒时间戳 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
回复消息
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 触发时机与来源 | 设备对下行命令或服务调用返回处理结果时触发。；用于理解和判断当前结果；不改变任务。 | 平台事件目录和实际事件分类。 | 命令回执同步、调用结果归档。 示例：设备返回 messageId 对应的执行成功结果。推荐：按对接资料填写默认：—示例：$events/reply | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 客户端标识（clientId） | 当前事件所属客户端，用于区分发送来源。；用于理解和判断当前结果；不改变任务。 | 会话或标准Alink sys中的客户端标识。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：FastBee_测温 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 设备键（deviceKey） | 跨协议定位设备的标识，不一定与客户端ID相同。；用于理解和判断当前结果；不改变任务。 | Alink sys及协议运行上下文。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：按实际设备键 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 消息ID（messageId） | 用于关联某条消息或回复；关联规则由发送方约定。；用于理解和判断当前结果；不改变任务。 | Alink id。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：本次命令关联ID | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 回复码（code） | 设备或服务返回的处理结果码，不是HTTP传输状态。；用于理解和判断当前结果；不改变任务。 | Alink回复的code字段。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：200 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 回复说明（message） | 补充回复结果含义；不能只凭文字判断设备已执行。；用于理解和判断当前结果；不改变任务。 | Alink回复的message字段。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：success | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 业务参数（params） | 属性值、事件参数或回复结果；对象可以为空。；用于理解和判断当前结果；不改变任务。 | 标准Alink params。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例： | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 消息文本（payloadText） | 消息文本表示；在标准Alink链路中通常是整个Alink JSON，不只是params。；用于理解和判断当前结果；不改变任务。 | 实际消息序列化结果。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：完整Alink JSON | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 事件时间（timestamp） | 事件上下文时间，通常是毫秒时间戳；不是监控采样时间。；用于理解和判断当前结果；不改变任务。 | sys.ts，缺失时由运行时按实现补充。 | 用于命令回执同步、调用结果归档。 先确认真实样本存在该字段，再写条件。缺失值先用 IS NULL / IS NOT NULL 判断。推荐：按对接资料填写默认：—示例：毫秒时间戳 | 字段目录不是非空保证。；在同类真实样本中确认字段来源和实际值，避免用页面默认样本代替。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
SQL 筛选与 Alink 消息
这里只使用事件规则支持的简单 SELECT、FROM 和 WHERE。可以组合 =、!=、>、>=、<、<=、LIKE、IS NULL、IS NOT NULL、AND、OR、NOT 与括号；不要套用 JOIN、子查询、聚合或数据库函数。
SELECT 字段主要帮助页面生成和阅读 SQL，当前运行时不会按 SELECT 列表裁剪外发内容。真正外发的是标准 Alink，业务值放在 params；clientId、protocol 等运行信息进入 sys，不要把内部上下文字段重新拼成业务参数。
SQL 与标准 Alink
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 已选 / 可选字段 | 选择按钮修改SELECT列表，主要便于生成和阅读SQL。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 所选事件的字段目录。 | 选择关注字段；选择不会删除外发params中的其他属性。推荐：按对接资料填写默认：—示例：clientId, deviceKey, protocol, params, timestamp | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| FROM 事件源 | 限制接收哪种事件。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 先选择页面事件，再使用对应事件源。 | 双引号包住事件源，属性上报使用本例值。推荐：按对接资料填写默认：—示例：FROM "$events/property_post" | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 筛选 SQL / WHERE | 决定哪条事件符合发送条件；没有WHERE时该源的事件均可通过。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 业务阈值和真实事件字段。 | 温度用数字31.5，不写带单位的字符串。含边界30，所以本例是达到30℃而不是严格超过30℃。推荐：按对接资料填写默认：—示例：SELECT clientId, deviceKey, protocol, params, timestamp FROM "$events/property_post" WHERE payloadJson.temperature >= 30 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| SELECT 不裁剪外发内容 | 当前运行时返回完整匹配上下文，Alink生成器独立组装消息。；用于理解和判断当前结果；不改变任务。 | SQL运行实现和Alink生成实现。 | 要控制敏感数据范围，不能只取消勾选字段；先确认上游提供的params。推荐：按对接资料填写默认：—示例：只选clientId，外发仍可包含temperature和humidity。 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 恢复默认字段 | 恢复当前事件的默认字段选择。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 恢复后再核对WHERE，事件切换也要重查SQL。推荐：按对接资料填写默认：—示例：恢复默认字段 | 默认字段并不表示消息完整性校验。；恢复后再核对WHERE，事件切换也要重查SQL。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| = | 等于；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：protocol = 'MQTT' | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| != | 不等于；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：code != 200 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| > | 严格大于；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：payloadJson.temperature > 30 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| >= | 大于等于；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：payloadJson.temperature >= 30 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| < | 严格小于；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：payloadJson.temperature < 30 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| <= | 小于等于；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：payloadJson.temperature <= 30 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| LIKE | 文本模式匹配，%表示任意长度，_表示单个字符；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：eventCode LIKE 'alarm%' | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| IS NULL | 判断缺失或空值，不等于空字符串；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：reason IS NULL | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| IS NOT NULL | 先判断字段存在，再比较；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：payloadJson.temperature IS NOT NULL | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| AND | 两边都满足；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：protocol = 'MQTT' AND payloadJson.temperature >= 30 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| OR | 至少一边满足；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：code = 200 OR code = 201 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| NOT | 对条件取反；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：NOT (code = 200) | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 括号 | 明确组合顺序，避免AND与OR组合误解；用于理解和判断当前结果；不改变任务。 | 业务判断和当前事件样本。 | 用一条满足、一条不满足的样本各检查一次；不套用完整数据库SQL行为。推荐：按对接资料填写默认：—示例：(code = 200 OR code = 201) AND messageId IS NOT NULL | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 消息标识（id） | 由来源Alink保留或平台生成，用于追踪消息；不能单靠字段存在判断幂等。；用于理解和判断当前结果；不改变任务。 | 来源Alink及平台标准消息生成器。 | 到外部队列查看实际收到的JSON，再核对设备、时间和业务值。推荐：按对接资料填写默认：—示例：FastBee_演示消息 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 版本（version） | 标准消息结构版本。；用于理解和判断当前结果；不改变任务。 | 来源Alink及平台标准消息生成器。 | 到外部队列查看实际收到的JSON，再核对设备、时间和业务值。推荐：按对接资料填写默认：—示例：1.0 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 方法（method） | 说明这是属性、事件、状态还是回复。属性上报使用thing.event.property.post。；用于理解和判断当前结果；不改变任务。 | 来源Alink及平台标准消息生成器。 | 到外部队列查看实际收到的JSON，再核对设备、时间和业务值。推荐：按对接资料填写默认：—示例：thing.event.property.post | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 系统上下文（sys） | 设备、协议、时间和来源信息；tenantId/productId等可以为空。不要将这组信息当作业务属性。；用于理解和判断当前结果；不改变任务。 | 来源Alink及平台标准消息生成器。 | 到外部队列查看实际收到的JSON，再核对设备、时间和业务值。推荐：按对接资料填写默认：—示例： | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 业务参数（params） | 实际测量值或业务事件内容。温度和湿度在这里，不在sys里。；用于理解和判断当前结果；不改变任务。 | 来源Alink及平台标准消息生成器。 | 到外部队列查看实际收到的JSON，再核对设备、时间和业务值。推荐：按对接资料填写默认：—示例： | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
五种推送目标参数参考
连接器级参数决定 FMQ 怎样连到外部系统，任务动作参数决定这条任务具体发到哪里。两者必须分开核对；连接器检查通过不能证明某个 Topic、Routing Key 或 URL 的业务接收方已经收到。
Kafka：连接与动作
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 连接器级：Broker 地址 | Kafka引导地址，可填逗号分隔的多个端点；仅任务内新建显示。高级连接配置见连接器手册。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 外部系统管理员提供；填写FMQ服务器实际可达的端点。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：按对接清单填写 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：Topic | 消息发布到哪个主题；页面预设只是快捷填值，不会替接收方创建消费程序。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接收系统负责人与发送方约定。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：FastBee_温度 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：消息 Key | 消息键可供分区或检索使用。模板替换取当前事件字段。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 由接收方约定分区键；字段来自事件上下文。 | 需要同设备使用稳定键时填${clientId}；无要求时与接收方约定留空。不能承诺跨分区顺序。推荐：按对接资料填写默认：—示例：$ | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
RabbitMQ：连接与动作
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 连接器级：Host | RabbitMQ主机，不要填写管理界面URL。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 外部系统管理员提供；填写FMQ服务器实际可达的端点。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：按对接清单填写 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：Port | AMQP端口，不是管理界面的15672。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 外部系统管理员提供；填写FMQ服务器实际可达的端点。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：5672（以部署为准） | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：用户名 | 用于连接Broker，应有对应vhost写权限。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | RabbitMQ管理员通过受控渠道提供。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：由管理员提供 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：密码 | 与RabbitMQ用户名对应的认证信息。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | RabbitMQ管理员通过受控渠道提供。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：受控填写，不写入手册 | 错误时认证失败；截图和日志不能出现明文。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：Virtual Host | Broker中的业务隔离空间，相同交换机名称可以存在于不同vhost。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | RabbitMQ管理员提供名称与授权范围。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：/（以部署为准） | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：发布确认 | 开启publisher_confirms后，实际成功来自Broker确认，仍不能证明目标队列实收。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 在连接器模块配置。 | 本实战明确开启后复用；任务内简化新建表单没有此开关，不能假定自动开启。推荐：按对接资料填写默认：—示例：true | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：Exchange | 这条任务向哪个交换机发布。动作值与连接器默认值分开核对；实战显式填写。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | RabbitMQ管理员提供已声明的交换机和类型。 | 本例使用topic交换机；不能把Queue名称填到这里。交换机为空时存在默认交换机语义，不作为本例配置。推荐：按对接资料填写默认：—示例：FastBee_push_7e9c24_exchange | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 必填 动作级：Routing Key | 匹配交换机与队列的绑定规则，决定消息进入哪个队列。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 队列Binding约定。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：FastBee.push.7e9c24 | 拼错仍可能得到Broker确认，但目标队列为0。；比较正确Binding并修正同一Routing Key，重新验证实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
RocketMQ：连接与动作
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 连接器级：NameServer | 服务发现地址，不是业务Topic；多个地址按部署约定分隔。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 外部系统管理员提供；填写FMQ服务器实际可达的端点。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：按对接清单填写 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：Producer Group | 发送端生产者组，不是接收方消费组。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | RocketMQ管理员约定的生产组。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：FastBee_push_group | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：Topic | 消息目标主题。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接收系统负责人与发送方约定。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：FastBee_温度 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：Tag | 消息标签，供接收方按类别筛选；不是设备属性。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接收方标签约定。 | 按对方订阅约定填具体标签；不要把订阅表达式的*误认为发送端会广播所有Tag。推荐：按对接资料填写默认：—示例：temperature | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：消息 Key | 消息检索标识，可使用事件字段模板，不是去重保证。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接收系统负责人与发送方约定。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：$ | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
WebHook：连接与动作
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 连接器级：请求方法 | 由接收接口契约决定；当前任务内新建提供POST、GET、PUT。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接口负责人提供方法。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：POSTPOST：提交数据；按接口契约产生写入GET：读取语义请求；不要默认认为能携带标准JSON正文PUT：写入或替换语义；必须确认是否会覆盖外部数据 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：URL | 包含协议、主机、端口及路径的完整接收地址。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接口负责人提供的测试环境地址。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：https://example.com/iot/events | 真实推送会真正请求接口，可能产生工单、通知等业务副作用。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 连接器级：Headers (JSON) | 请求头对象，可携带内容类型及接口所需鉴权；复用模式读取已有连接器。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接口文档；鉴权值只经受控渠道取得。 | 使用JSON对象，不写成数组或逗号分隔字符串。认证头不得进入截图。推荐：按对接资料填写默认：—示例： | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：标准Alink请求体 | 本页不提供自定义业务消息模板。复用连接器时也不会覆盖原URL、方法和Headers。；用于理解和判断当前结果；不改变任务。 | 平台统一Alink生成器及已选连接器。 | 以接口实际接收内容验证；仅有HTTP响应也不必然等于业务处理完成。推荐：按对接资料填写默认：—示例：id、version、method、sys、params | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
MQTT：连接与动作
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 连接器级：外部Broker | 外部连接器保存Host、Port、发布客户端ID及认证；任务内新建MQTT目前是本地模式，不等于连接外部Broker。；用于理解和判断当前结果；不改变任务。 | 连接器模块中已校验的MQTT连接器。 | 要向外部Broker发送，先在连接器模块建外部连接器，再在此选择复用。推荐：按对接资料填写默认：—示例：外部连接器 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：客户端 ID | 本地模式用于定位目标在线会话；外部模式使用连接器的发布客户端身份，不以此字段指定外部订阅者。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 事件上下文和目标会话约定。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：$ | 把本地动作clientId与外部发布clientId混用会导致目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 必填 动作级：Topic | 实际发布的主题，支持事件字段模板。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 与订阅方约定。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：/${clientId}/property/post | 发布回同一自动规则入口可能形成重复转发；应使用独立出站Topic。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：QoS | 选择MQTT传输交付等级，不是外部系统业务处理完成保证。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 与接收方和Broker支持范围共同确定。 | 先与接收方核对，再用实际消息确认目标收到了正确内容。推荐：按对接资料填写默认：—示例：00：最多一次；不等待协议级确认1：至少一次；可能重复，接收方应能去重2：协议级恰好一次；握手开销更大，仍不等于业务处理恰好一次 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 动作级：Retain | 要求Broker保留该Topic的最后一条消息，供后来的订阅者获得。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 接收方是否需要最后已知状态。 | 普通告警事件通常关闭；需要新订阅者读取最后状态时再开启。推荐：按对接资料填写默认：—示例：false | 开启可能让新订阅者读到旧告警；清理测试时须检查保留消息。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
检查、监控、维护与排障
“检查一下”只做规则命中和推送预览；“真实推送”会调用真实动作。监控中的提交成功表示任务进入发送队列，Broker 实际成功表示中间件确认，外部实收仍要在目标队列、Topic 或接口侧验证。
最近日志默认关闭，因此空日志不能单独判定任务异常。优先看积压、提交成功/失败、丢弃、Broker 实际成功/失败、队列容量和最近异常，再按链路定位。多动作任务可以查看、测试、启停和删除，但当前不支持在此页面编辑或复制。
25. 用搜索、筛选和刷新定位任务
操作位置： 集成→消息推送
按任务名称搜索，按启用状态筛选；需要最新计数时点击刷新。
图：按任务名搜索并刷新，目标任务在当前筛选结果中可见。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 搜索 | 按任务身份和页面支持的描述范围定位。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：当前列表中的任务名称等信息。选择：搜不到时先清空条件和状态筛选。推荐：按对接资料填写 · 示例：FastBee_温度告警推送 |
| 状态筛选 | 只显示选定启停状态的任务。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：任务当前状态。选择：排查找不到任务时先切全部。推荐：按对接资料填写 · 示例：全部 |
26. 编辑简单任务
操作位置： 集成→消息推送
打开简单任务的编辑入口，修改前先记录 SQL、动作和连接器引用。
图：打开本批次简单任务的编辑表单，核对名称与配置；本次不修改业务参数。
27. 复制简单任务
操作位置： 集成→消息推送
点击 复制，修改新任务名称和目标后再保存。
图：复制草稿已改名并关闭启用，原任务不变；本次取消，不创建重复任务。
28. 停用不再自动触发的任务
操作位置： 集成→消息推送
点击 停用，确认状态变为停用。
图：任务当前已停用，不再自动匹配实时事件。
字段说明
| 字段 / 控件 | 说明 |
|---|---|
| 启用状态 | 开启后参与实时事件匹配；关闭后不自动触发，但人工真实推送仍能发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。选填 · 来源：按当前调试或上线阶段选择。选择：新建默认可能开启，本例必须手动关闭，闭环验证后再开启。推荐：按对接资料填写 · 示例：停用 |
29. 查看删除影响，本次先取消
操作位置： 集成→消息推送
点击 删除，阅读确认框中的任务名称和清理范围；因为该任务还要用于新手盲测，本次点击取消。
图：删除确认展示任务名称和影响范围；本次先取消，待精确资源核对后统一清理。
检查、监控及日常操作
| 字段 | 用途 | 值从哪里来 | 怎么选择 | 填错表现与恢复 | 生效条件 |
|---|---|---|---|---|---|
| 检查一下 | 计算SQL是否命中并生成预览，不调用真实目标。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 先用25℃和31.5℃各检查一次，分别看到不命中和命中。推荐：按对接资料填写默认：—示例：检查一下 | 检查成功不能代替网络、Broker和实收验证。；先用25℃和31.5℃各检查一次，分别看到不命中和命中。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 真实推送 | 对当前模拟事件执行真实动作，停用任务也可以发送。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 确认隔离目标后再点击，随后看监控和外部实收。推荐：按对接资料填写默认：—示例：真实推送 | 会产生外部业务副作用。；确认隔离目标后再点击，随后看监控和外部实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 监控 | 打开任务发送监控，分别显示提交与实际结果。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 在发送前后同一观察窗口比较增量；当前计数不等于永久历史总数。推荐：按对接资料填写默认：—示例：监控 | 不要把其他时间的成功数当成本次成功。；在发送前后同一观察窗口比较增量；当前计数不等于永久历史总数。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 搜索 | 按任务身份和页面支持的描述范围定位。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前列表中的任务名称等信息。 | 搜不到时先清空条件和状态筛选。推荐：按对接资料填写默认：—示例：FastBee_温度告警推送 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 状态筛选 | 只显示选定启停状态的任务。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 任务当前状态。 | 排查找不到任务时先切全部。推荐：按对接资料填写默认：—示例：全部全部：全部任务；不限制状态启用：正在匹配实时事件；隐藏停用任务停用：不自动触发；隐藏启用任务 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 刷新 | 重新加载列表或当前监控。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 看清当前采样时间，网络错误先检查访问状态。推荐：按对接资料填写默认：—示例：刷新 | 刷新不重发消息。；看清当前采样时间，网络错误先检查访问状态。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 启用 | 让规则参与实时匹配。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 真实推送验证成功且目标实收后再启用。推荐：按对接资料填写默认：—示例：启用 | 可能立即处理进入平台的所有命中事件。；真实推送验证成功且目标实收后再启用。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 停用 | 停止实时事件自动触发。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 维护或删除前先停用，并观察积压是否排空。推荐：按对接资料填写默认：—示例：停用 | 已进入发送队列的消息仍可能完成；人工真实推送不受此限制。；维护或删除前先停用，并观察积压是否排空。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 编辑 | 修改简单任务的规则或动作。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 记录原值，保存后重新验证；多动作任务不支持。推荐：按对接资料填写默认：—示例：编辑 | 修改共享对象时页面可能复制新对象，需核对引用。；记录原值，保存后重新验证；多动作任务不支持。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 复制 | 以简单任务创建新草稿，原任务保留。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 修改名称并先停用，核对连接器是复用还是新建。推荐：按对接资料填写默认：—示例：复制 | 新旧规则同时启用可能重复推送。；修改名称并先停用，核对连接器是复用还是新建。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 删除 | 删除规则；简单任务页面还会尝试删除动作和连接器。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 当前页面的操作入口。 | 先停用并确认对象是否专用；共享资源不随意删除。推荐：按对接资料填写默认：—示例：删除 | 没有撤销按钮，恢复需按备份配置重建。；先停用并确认对象是否专用；共享资源不随意删除。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 删除的共享资源边界 | 仍被本地动作引用的连接器会拒绝删除；没有剩余引用的连接器可能被页面顺带删掉。；用于理解和判断当前结果；不改变任务。 | 页面删除流程和连接器引用检查。 | 删除前到连接器模块核对用途和引用，不能只假定平台会永久保留复用连接器。推荐：按对接资料填写默认：—示例：取消不明确的删除 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 多动作任务限制 | 支持查看、测试、启停和删除，不支持当前页面编辑或复制。；用于理解和判断当前结果；不改变任务。 | 任务动作数量。 | 逐个查看测试结果，不能只看第一个目标。推荐：按对接资料填写默认：—示例：动作数大于1 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 最近日志 | 默认关闭；关闭时列表为空。；用于理解和判断当前结果；不改变任务。 | 规则执行日志配置和近期查询结果。 | 先看监控计数；需要日志时联系运维按需开启并评估负载。推荐：按对接资料填写默认：—示例：空列表不代表异常 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 外部队列实收 | 从目标队列实际读取到本次消息，才证明目标路由成立。；用于理解和判断当前结果；不改变任务。 | RabbitMQ管理界面或获准消费者。 | 核对队列名、设备标识、时间和温度；读取确认会移除消息，只在专用队列操作。推荐：按对接资料填写默认：—示例：params.temperature=31.5 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| LinkPilot真实输入 | 用真实设备工具会话发送属性事件，不点击FMQ真实推送。；用于理解和判断当前结果；不改变任务。 | LinkPilot GUI的连接与发送记录。 | 核对客户端、目标Broker、Topic和32.6℃内容，再到目标队列按同一消息核对。推荐：按对接资料填写默认：—示例：32.6℃ | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 积压数 | 已经提交但尚未完成的发送任务数量。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：条；当前运行统计。 | 停止输入后应趋向0；持续输入时短暂积压不一定异常。 停止输入后仍持续增加或不下降，先查Broker耗时和失败。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 提交成功数 | 成功进入本地发送队列的动作数，不是Broker确认数。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：次；当前运行统计。 | 规则命中并发起发送后应增加。 事件命中却不增加，检查动作与连接器引用。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 提交失败数 | 提交动作失败的计数。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：次；当前运行统计。 | 本次正常提交时不应增加。 增加时先核对动作必填参数和错误反馈。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 丢弃数 | 发送队列过载等情况下未保留的任务数。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：次；当前运行统计。 | 正常容量下不应随本次发送增加。 增加先看容量和积压；不能仅反复重发。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 实际成功 | 发送层记录的实际成功。本例开启发布确认后对应RabbitMQ确认。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：次；当前运行统计。 | 实际发送完成后增加；仍需目标队列实收。 提交增加但这里不增加，检查积压及实际失败。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 实际失败 | Broker发送或确认失败的计数。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：次；当前运行统计。 | 本次正常发送不应增加。 增加先看最近异常和连接器状态。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 队列容量 | FMQ本地发送队列容量，不是RabbitMQ队列容量。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：条；当前运行统计。 | 剩余容量足以接纳当前流量。 剩余接近0且积压增长，检查下游处理速度。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 剩余容量 | 本地发送队列当前可用空间。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：条；当前运行统计。 | 低负载通常较多，空闲时可接近总容量。 持续接近0时降低输入并检查Broker。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 最近异常 | 最近一次Broker发送错误，不是SQL检查错误。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：文本；当前运行统计。 | 无错误时为空；历史错误须结合失败时间判断。 新错误出现时按其连接、权限或超时原因检查。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 采样时间 | 本监控快照取数时间，不是消息发生时间。；用于理解和判断当前结果；不改变任务。 | 任务监控快照，单位：时间；当前运行统计。 | 打开监控时随刷新更新。 长期不更新先查页面网络，不把旧数当实时结果。推荐：按对接资料填写默认：—示例：以本次发送前后差值为准 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 提交数/秒 | 相邻采样的提交成功增量除以时间差。；用于理解和判断当前结果；不改变任务。 | 页面相邻监控采样，通常每3秒刷新；首个采样不能形成速率。 | 有输入时随负载变化；业务静默为0正常。推荐：按对接资料填写默认：—示例：条/秒 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 实际发送/秒 | 相邻采样的Broker成功增量除以时间差。；用于理解和判断当前结果；不改变任务。 | 页面相邻监控采样，通常每3秒刷新；首个采样不能形成速率。 | 有积压而长期为0时，检查实际失败及Broker可用性。推荐：按对接资料填写默认：—示例：条/秒 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 测试来源客户端 | 测试事件的来源标识，不会自动建立真实设备连接。；只影响下一次检查或人工真实推送，不改变真实设备事件。 | 当前测试样本或真实脱敏事件。 | 本例选择JSON模式，只调整temperature为25或31.5。推荐：按对接资料填写默认：—示例：FastBee_测温 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 测试消息主题 | 测试事件的来源Topic，不是RabbitMQ目的队列。；只影响下一次检查或人工真实推送，不改变真实设备事件。 | 当前测试样本或真实脱敏事件。 | 本例选择JSON模式，只调整temperature为25或31.5。推荐：按对接资料填写默认：—示例：/FastBee_测温/property/post | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| JSON业务内容 | 输入JSON对象，平台放入Alink params。；只影响下一次检查或人工真实推送，不改变真实设备事件。 | 当前测试样本或真实脱敏事件。 | 本例选择JSON模式，只调整temperature为25或31.5。推荐：按对接资料填写默认：—示例： | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 文本内容 | 文本写入params.payloadText；没有temperature数字就不能套用本例温度条件。；只影响下一次检查或人工真实推送，不改变真实设备事件。 | 当前测试样本或真实脱敏事件。 | 本例选择JSON模式，只调整temperature为25或31.5。推荐：按对接资料填写默认：—示例：hello | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| Hex内容 | 偶数长度十六进制，写入params.payloadHex并附带payloadLength。；只影响下一次检查或人工真实推送，不改变真实设备事件。 | 当前测试样本或真实脱敏事件。 | 本例选择JSON模式，只调整temperature为25或31.5。推荐：按对接资料填写默认：—示例：6869 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| Base64内容 | Base64表示写入params.payloadBase64；不是自动把字节解析成温度。；只影响下一次检查或人工真实推送，不改变真实设备事件。 | 当前测试样本或真实脱敏事件。 | 本例选择JSON模式，只调整temperature为25或31.5。推荐：按对接资料填写默认：—示例：aGk= | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 附加字段 | 为测试事件补充协议和时间等上下文；JSON对象，不能输入凭据。；只影响下一次检查或人工真实推送，不改变真实设备事件。 | 当前测试样本或真实脱敏事件。 | 本例选择JSON模式，只调整temperature为25或31.5。推荐：按对接资料填写默认：—示例： | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
| 测试内容模式 | 选择测试业务内容的编码形式。；保存后影响当前任务的后续检查或发送；用新样本重新验证结果。 | 待验证报文类型。 | 温度实战选JSON；其他形式先改写相应WHERE。推荐：按对接资料填写默认：—示例：JSONJSON：用JSON表示业务内容；切换后检查实际Alink预览文本：用文本表示业务内容；切换后检查实际Alink预览Hex：用Hex表示业务内容；切换后检查实际Alink预览Base64：用Base64表示业务内容；切换后检查实际Alink预览 | 取值与实际事件或对接约定不同，会导致未命中或发送目标错误。；对照取值来源修正，再检查并验证目标实收。 | 范围：当前消息推送任务发布：不需要 · 重启：不需要 · 重连：不需要 |
参考表 2
| 看到什么现象 | 可能原因 | 先检查哪里 | 如何恢复 |
|---|---|---|---|
| 25℃也显示命中 | WHERE 条件或字段路径写错 | 核对 payloadJson.temperature 和 >= 30 | 修正 SQL，先重复不命中检查 |
| 检查命中但没有执行发送 | 使用的是检查一下，或真实推送请求未提交 | 看 dryRun 与 dispatched | 确认隔离目标后点击真实推送 |
| 提交成功但 Broker 实际成功不增加 | 本地积压、连接异常或发送失败 | 看积压、实际失败和最近异常 | 修正连接器后重测，不重复堆积请求 |
| Broker 成功但 RabbitMQ 队列为 0 | Exchange、Routing Key 或队列绑定不匹配 | 逐项比较任务动作与 RabbitMQ Binding | 改回正确 Routing Key，再以同一连接复测实收 |
| 最近日志为空 | 最近日志能力默认关闭或当前窗口无记录 | 先看监控计数和运行配置 | 不要仅凭空日志判失败，按需启用受控日志后再查 |
| 找不到编辑或复制 | 任务包含多个动作 | 查看动作数量和页面提示 | 保留原任务，按摘要手动新建简单任务或使用支持的查看、测试、启停、删除操作 |
生产操作提示
截图和示例用于说明操作位置与判断方法，不代表当前生产状态。涉及发布、启停、重绑、重试或删除时，应先确认目标环境、影响范围和恢复方案，并由授权人员执行。
蜂信物联（FastBee） · FMQ 操作手册