EMQX Agents 是运行在 EMQX Cloud 上的事件驱动 Agent Runtime,原生连接 MQTT Broker、时序数据表和设备群。用自然语言描述目标,即可在几分钟内生成并部署可用于生产的 Agent。
当 Agent 面向工业现场执行动作时,错误命令可能影响电机、产线和告警响应。因此,每次运行都必须可控、可审计、可回放。
这些能力都作为 EMQX Cloud 托管服务交付,共同完成从事件触发、上下文获取到安全执行的闭环。
根据事件、历史数据和设备状态判断下一步动作,并调用工具执行。可单独连接某一层,也可以贯通 Broker、Tables 和 Fleets。
MQTT Trigger · Broker
factory/+/temperature · 实时
Agent Loop
推理 · 调用工具
决策 · 执行动作
Tables
查询历史
7 天基线
Fleets
设备状态
dev-0042 · shadow
Broker
发布命令
cmd/maintenance
实时事件进入系统的入口。面向全球规模连接的 MQTT Broker。
为遥测数据保留可查询的历史记忆,提供托管时序存储。
管理设备影子、分组、命令和 OTA 任务,让 Agent 能读取状态并安全执行动作。
不需要额外 Webhook,也不需要手写拼接代码。Agent 闭环直接运行在 EMQX Cloud 内。
Agent 可以直接订阅主题。EMQX Rule Engine 会先在高吞吐消息流中完成过滤、去抖和批处理,只有真正需要推理的事件才会进入 LLM。
Agent 可从 EMQX Tables 读取 7 天基线,检查 Fleets 中的设备影子,请求人工审批,再通过 Broker 发布命令。读取、决策、执行和观察都在同一平台内完成。
平台提供告警分诊、预测性维护、OTA 发布保护、影子同步、UNS 助手等模板和 Skills。你可以从可用模板开始,而不是从一段空白提示词开始。
用自然语言说明目标。Meta-agent 会自动生成系统提示词、触发器、工具授权和 Skills。
› 机械臂遥测超过 30 秒没有上报时 通知值班人员。
在线编辑生成的规范。你可以替换工具、收紧策略,并在上线前用真实主题先跑 dry-run。
先发布到预发环境,再推广到生产环境。每次运行都有 trace、成本和回放记录。
| 运行 | 状态 | 耗时 | 成本 |
|---|---|---|---|
| 3a32c351 | 成功 | 12.7 s | $0.22 |
| 4379a5ed | 成功 | 9.7 s | $0.22 |
| 5beb2855 | 成功 | 10.9 s | $0.22 |
MQTT 触发、MCP 工具、Skills、沙箱、护栏和 trace 贯穿一条可执行闭环,让 Agent 能安全地对真实系统执行动作。
topic filter
factory/+/robot/+
robot.telemetry.v2
单设备 30 s
site · line · model
验证 payload
在 Agent 循环启动前拦截格式错误的事件。
把高频 MQTT 遥测整理成一次带完整上下文的 Agent 运行。
连接器是 Agent 操作外部系统的类型化 MCP 工具。EMQX Cloud 内置常用工具,也支持接入你自己的 MCP Server。
每个 EMQX Agent 都有独立身份、明确的主题白名单、按工具划分的权限范围和预算上限。高风险动作在触达设备前,必须先经过人工审批。
factory/+/telemetry
factory/+/cmd/maintenance
查看任意一次运行的触发器、上下文获取、LLM 调用、工具调用和设备确认。你可以重放它、基于它做评估,再放心发布下一个版本。
3a32c351
13
561
16,105
$0.22
面向大量 PLC 和产线设备的异常分诊与影子同步。
风机基线漂移检测、预测性维护,以及受 KPI 约束的 OTA 发布。
车辆遥测分诊、安全可控的固件发布,以及地理围栏规则执行。
HVAC 自动调优、基于占用情况的控制,以及需人工审批的楼宇自动化。
关于 EMQX Agents 的常见问题。
我们会按批次开放名额,并由工程团队提供上手支持。告诉我们你的使用场景,我们会在两个工作日内联系你。