New
EMQX 6.2 新特性:A2A over MQTT 智能体发现与协作 →
EMQX Agents Private Beta 开放中

让 Agent 基于实时数据决策与行动

EMQX Agents 是运行在 EMQX Cloud 上的事件驱动 Agent Runtime,原生连接 MQTT Broker、时序数据表和设备群。用自然语言描述目标,即可在几分钟内生成并部署可用于生产的 Agent。

联系我们

多数 AI Agent 只停留在屏幕上,而你的 Agent 要驱动真实设备

当 Agent 面向工业现场执行动作时,错误命令可能影响电机、产线和告警响应。因此,每次运行都必须可控、可审计、可回放。

架构

一个平台,串起事件、记忆、执行和决策

这些能力都作为 EMQX Cloud 托管服务交付,共同完成从事件触发、上下文获取到安全执行的闭环。

大脑

EMQX Agents

Private Beta

根据事件、历史数据和设备状态判断下一步动作,并调用工具执行。可单独连接某一层,也可以贯通 Broker、Tables 和 Fleets。

MQTT Trigger · Broker

factory/+/temperature · 实时

Agent Loop

推理 · 调用工具

决策 · 执行动作

Tables

查询历史

7 天基线

Fleets

设备状态

dev-0042 · shadow

Broker

发布命令

cmd/maintenance

正式可用
神经系统

EMQX Broker

实时事件进入系统的入口。面向全球规模连接的 MQTT Broker。

正式可用
记忆

EMQX Tables

为遥测数据保留可查询的历史记忆,提供托管时序存储。

Private Beta
执行器

EMQX Fleets

管理设备影子、分组、命令和 OTA 任务,让 Agent 能读取状态并安全执行动作。

闭环执行

从 MQTT 消息到决策,再到设备命令

不需要额外 Webhook,也不需要手写拼接代码。Agent 闭环直接运行在 EMQX Cloud 内。

核心价值

EMQX Agents 解决的三个关键问题

01

以 MQTT 事件原生触发

Agent 可以直接订阅主题。EMQX Rule Engine 会先在高吞吐消息流中完成过滤、去抖和批处理,只有真正需要推理的事件才会进入 LLM。

02

连接历史数据与设备动作

Agent 可从 EMQX Tables 读取 7 天基线,检查 Fleets 中的设备影子,请求人工审批,再通过 Broker 发布命令。读取、决策、执行和观察都在同一平台内完成。

03

内置工业场景模板

平台提供告警分诊、预测性维护、OTA 发布保护、影子同步、UNS 助手等模板和 Skills。你可以从可用模板开始,而不是从一段空白提示词开始。

使用方式

从一句需求到上线 Agent,只需三步

1

描述

用自然语言说明目标。Meta-agent 会自动生成系统提示词、触发器、工具授权和 Skills。

描述

› 机械臂遥测超过 30 秒没有上报时 通知值班人员。

trigger
factory/+/robot/+
tools
broker · tables · humans
skills
sparkplug-b, incident-triage
2

调整

在线编辑生成的规范。你可以替换工具、收紧策略,并在上线前用真实主题先跑 dry-run。

调整
trigger
factory/site-a/+/robot/+
debounce
30 s
budget
$2 / run · $50 / day
approval
PagerDuty · oncall-l1
Dry Run · Ready
3

部署

先发布到预发环境,再推广到生产环境。每次运行都有 trace、成本和回放记录。

部署
运行状态耗时成本
3a32c351成功12.7 s$0.22
4379a5ed成功9.7 s$0.22
5beb2855成功10.9 s$0.22
能力

为真实设备和生产环境准备的 Agent Runtime

MQTT 触发、MCP 工具、Skills、沙箱、护栏和 trace 贯穿一条可执行闭环,让 Agent 能安全地对真实系统执行动作。

触发处理
实时

topic filter

factory/+/robot/+

实时
schema

robot.telemetry.v2

debounce

单设备 30 s

batch

site · line · model

验证 payload

在 Agent 循环启动前拦截格式错误的事件。

把高频 MQTT 遥测整理成一次带完整上下文的 Agent 运行。

连接器

通过 MCP 连接器扩展 Agent 能力

连接器是 Agent 操作外部系统的类型化 MCP 工具。EMQX Cloud 内置常用工具,也支持接入你自己的 MCP Server。

安全与治理

能向一个主题发布命令,不代表能向所有主题发布命令

每个 EMQX Agent 都有独立身份、明确的主题白名单、按工具划分的权限范围和预算上限。高风险动作在触达设备前,必须先经过人工审批。

主题白名单(发布 / 订阅分离)
按表和设备分组限制读取范围
批量命令的影响范围上限
首次执行必须 dry-run
单次调用和单个 Agent 的成本上限
维护窗口强制执行
每次运行的完整审计轨迹
agent · predictive-maintenance-eu
Production
subscribe

factory/+/telemetry

publish

factory/+/cmd/maintenance

tables.read
telemetry · last 30d
fleets.scope
group:turbines-EU
approval
required · blast > 10
budget
$5 / run · $200 / day
可观测性

每次运行都有完整 Trace

查看任意一次运行的触发器、上下文获取、LLM 调用、工具调用和设备确认。你可以重放它、基于它做评估,再放心发布下一个版本。

运行
成功

3a32c351

输入 token

13

输出 token

561

缓存 token

16,105

成本

$0.22

使用场景

EMQX Agents 适用的典型场景

制造业

面向大量 PLC 和产线设备的异常分诊与影子同步。

能源与公用事业

风机基线漂移检测、预测性维护,以及受 KPI 约束的 OTA 发布。

移动出行与车队

车辆遥测分诊、安全可控的固件发布,以及地理围栏规则执行。

智慧基础设施

HVAC 自动调优、基于占用情况的控制,以及需人工审批的楼宇自动化。

常见问题

关于 EMQX Agents 的常见问题。

加入 EMQX Agents Private Beta

我们会按批次开放名额,并由工程团队提供上手支持。告诉我们你的使用场景,我们会在两个工作日内联系你。

联系我们
Beta 期间免费试用完整功能。
直接对接产品研发团队。
提供模板和示例数据集,几分钟内即可跑通演示。