EMQX Agents is the event-driven agent runtime on EMQX Cloud, natively wired to your MQTT broker, time-series tables, and device fleets. Describe what you want; deploy a production-grade agent in minutes.
When an agent acts on the physical world, every decision carries weight: a wrong command moves a real motor, a missed alert costs real money. That's the bar Physical AI has to clear, on every run.
Each layer is a managed service on EMQX Cloud. Together they close the loop from event to decision to action.
Decides what to do next. Reasons over events, history, and device state, then acts. Use it with any one of the layers, a few of them, or all three.
MQTT Trigger · Broker
factory/+/temperature · Real-Time
Agent Loop
Reason · Call Tools
Decide · Act
Tables
Query History
7-Day Baseline
Fleets
Device State
dev-0042 · Shadow
Broker
Publish Command
cmd/maintenance
Where every event happens, in real time. The world's most scalable MQTT broker.
Where the past is recorded and queried. A managed time-series store for telemetry.
Knows device state and changes it. Manage shadows, groups, commands, and OTA jobs.
No webhooks. No glue code. The full loop runs on one platform.
Agents subscribe to topics as a first-class trigger. The deterministic preprocessor (built on EMQX's Rule Engine) filters, debounces, and batches at million-message scale before any LLM is called.
Agents read 7-day baselines from EMQX Tables, inspect shadows in EMQX Fleets, request human approval, and publish commands back through the broker. Read, decide, act, observe. All on one platform.
Templates and Skills ship with the platform: alarm triage, predictive maintenance, OTA rollout guard, shadow reconciliation, UNS assistant. Start from a template, not from a blank prompt.
Type your goal in plain English. A meta-agent drafts your system prompt, trigger, tool grants, and skills.
› Page on-call when robot-arm telemetry stalls for more than 30 seconds.
Edit the generated spec inline. Swap tools, tighten guardrails, dry-run against a real topic before going live.
Promote to staging, then production. Every run is traced, costed, and replayable.
| Run | Status | Duration | Cost |
|---|---|---|---|
| 3a32c351 | Succeeded | 12.7 s | $0.22 |
| 4379a5ed | Succeeded | 9.7 s | $0.22 |
| 5beb2855 | Succeeded | 10.9 s | $0.22 |
Trigger intake, MCP tools, skills, sandboxing, guardrails, and traces — one runtime for agents that act on real systems.
Topic Filter
factory/+/robot/+
robot.telemetry.v2
30 s per device
site · line · model
Validate Payload
Reject malformed events before the agent loop starts.
Turns high-frequency MQTT telemetry into one clean agent run with validated context.
Connectors are typed MCP tools your agent calls to act on the world. Native to EMQX Cloud, and any MCP server you bring.
Every EMQX Agent has its own identity, an explicit topic allowlist, a per-tool permission scope, and hard budget caps. High-risk actions route through human approval before they touch a device.
factory/+/telemetry
factory/+/cmd/maintenance
See the trigger, the context fetched, every LLM call, every tool call, and every device ack, for any run. Replay it, eval against it, ship the next version with confidence.
3a32c351
13
561
16,105
$0.22
Line-level anomaly triage and shadow reconciliation across thousands of PLCs.
Turbine baseline drift, predictive maintenance, and KPI-gated OTA rollouts.
Vehicle telemetry triage, recall-safe firmware rollouts, geofence rules.
HVAC autotuning, occupancy-aware control, human-approved building automation.
Everything you need to know about EMQX Agents.
Cohorts onboard weekly with hands-on support from the engineering team. Tell us a little about your use case and we'll be in touch within two business days.