Start with MQTT events
Trigger agents with MQTT messages and process each event with scoped tools.
EMQX Agents · Public Beta
AI Agents for the
Physical World
Build and run agents that respond to MQTT events, reason over device telemetry, and act through connected tools.
Natural language prompt Ready
Page on-call when robot-arm telemetry stalls for more than 30 seconds.
Example agent specification
- Trigger
- factory/+/robot/+/telemetry
- Debounce
- 30s silence detection
- Tools
- brokertablesteams
- Action
- Post incident context to the on-call Teams channel
Why EMQX Agents
From real-time events to intelligent action
Give every signal context
Combine current telemetry with historical data and schema information.
Run alongside your data
Fully managed on EMQX Cloud, in the same VPC as your data.
Capabilities
Build. Connect. Run.
Natural-language setup
Describe a task. Review and refine the generated instructions before deployment.
MQTT-native triggers
Start from MQTT messages, validate payloads, and publish results to allowed topics.
Telemetry queries
Query EMQX Tables with SQL to compare readings and retrieve relevant history.
Connected tools
Connect knowledge sources and team tools through supported MCP connectors.
Templates and skills
Start from a template or reuse your team’s instructions to create similar agents.
Traces & observability
Inspect execution status, tool calls, token usage, and reported LLM cost.
Connectors
Connect agents to your data and tools
'%3e%3crect%20width='152'%20height='130'%20x='20'%20y='52'%20fill='%23bbe2ff'%20rx='65'/%3e%3crect%20width='172'%20height='152'%20x='10'%20y='14'%20fill='%233186ff'%20rx='74'/%3e%3cmask%20id='d'%20width='172'%20height='152'%20x='10'%20y='14'%20maskUnits='userSpaceOnUse'%20style='mask-type:alpha'%3e%3crect%20width='172'%20height='152'%20x='10'%20y='14'%20fill='%233c90ff'%20rx='74'/%3e%3c/mask%3e%3cg%20filter='url(%23b)'%20mask='url(%23d)'%3e%3crect%20width='152'%20height='130'%20x='20'%20y='52'%20fill='url(%23e)'%20rx='65'/%3e%3c/g%3e%3cg%20clip-path='url(%23f)'%3e%3cpath%20stroke='%23fff'%20stroke-linecap='round'%20stroke-linejoin='round'%20stroke-width='12'%20d='m61%2090%2022.172%2022.172a4%204%200%200%200%205.656%200L138%2063'/%3e%3c/g%3e%3c/g%3e%3cdefs%3e%3cclipPath%20id='a'%3e%3cpath%20fill='%23fff'%20d='M0%200h192v192H0z'/%3e%3c/clipPath%3e%3cclipPath%20id='f'%3e%3cpath%20fill='%23fff'%20d='M44%2038h104v104H44z'/%3e%3c/clipPath%3e%3clinearGradient%20id='e'%20x1='96'%20x2='100.64'%20y1='166.9'%20y2='67.25'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20offset='.01'%20stop-color='%23a9a8ff'/%3e%3cstop%20offset='.79'%20stop-color='%23a9a8ff'%20stop-opacity='0'/%3e%3c/linearGradient%3e%3cfilter%20id='b'%20width='176'%20height='154'%20x='8'%20y='40'%20color-interpolation-filters='sRGB'%20filterUnits='userSpaceOnUse'%3e%3cfeFlood%20flood-opacity='0'%20result='BackgroundImageFix'/%3e%3cfeBlend%20in='SourceGraphic'%20in2='BackgroundImageFix'%20result='shape'/%3e%3cfeGaussianBlur%20result='effect1_foregroundBlur_37601_9976'%20stdDeviation='6'/%3e%3c/filter%3e%3c/defs%3e%3c/svg%3e)
%20--%3e%3cdefs%3e%3cstyle%3e%20.st0%20{%20fill:%20%2341b658;%20}%20.st1%20{%20fill:%20%2300b3ff;%20}%20.st2%20{%20fill:%20%23e3066a;%20}%20.st3%20{%20fill:%20%23fcc003;%20}%20%3c/style%3e%3c/defs%3e%3cg%3e%3cpath%20class='st2'%20d='M84.039,252.769c0,23.127-18.893,42.02-42.02,42.02S0,275.896,0,252.769s18.893-42.02,42.02-42.02h42.02v42.02Z'/%3e%3cpath%20class='st2'%20d='M105.212,252.769c0-23.127,18.893-42.02,42.02-42.02s42.02,18.893,42.02,42.02v105.212c0,23.127-18.893,42.02-42.02,42.02s-42.02-18.893-42.02-42.02c0,0,0-105.212,0-105.212Z'/%3e%3c/g%3e%3cg%3e%3cpath%20class='st1'%20d='M147.231,84.039c-23.127,0-42.02-18.893-42.02-42.02S124.104,0,147.231,0s42.02,18.893,42.02,42.02v42.02h-42.02Z'/%3e%3cpath%20class='st1'%20d='M147.231,105.212c23.127,0,42.02,18.893,42.02,42.02s-18.893,42.02-42.02,42.02H42.02c-23.127,0-42.02-18.893-42.02-42.02s18.893-42.02,42.02-42.02c0,0,105.212,0,105.212,0Z'/%3e%3c/g%3e%3cg%3e%3cpath%20class='st0'%20d='M315.961,147.231c0-23.127,18.893-42.02,42.02-42.02s42.02,18.893,42.02,42.02-18.893,42.02-42.02,42.02h-42.02v-42.02Z'/%3e%3cpath%20class='st0'%20d='M294.788,147.231c0,23.127-18.893,42.02-42.02,42.02s-42.02-18.893-42.02-42.02V42.02c0-23.127,18.893-42.02,42.02-42.02s42.02,18.893,42.02,42.02v105.212Z'/%3e%3c/g%3e%3cg%3e%3cpath%20class='st3'%20d='M252.769,315.961c23.127,0,42.02,18.893,42.02,42.02s-18.893,42.02-42.02,42.02-42.02-18.893-42.02-42.02v-42.02h42.02Z'/%3e%3cpath%20class='st3'%20d='M252.769,294.788c-23.127,0-42.02-18.893-42.02-42.02s18.893-42.02,42.02-42.02h105.212c23.127,0,42.02,18.893,42.02,42.02s-18.893,42.02-42.02,42.02h-105.212Z'/%3e%3c/g%3e%3c/svg%3e)
'/%3e%3cpath%20d='M63.7076%20110.284C60.8481%20113.885%2055.0502%20111.912%2054.9813%20107.314L53.9738%2040.0627L99.1935%2040.0627C107.384%2040.0627%20111.952%2049.5228%20106.859%2055.9374L63.7076%20110.284Z'%20fill='url(%23paint1_linear)'%20fill-opacity='0.2'/%3e%3cpath%20d='M45.317%202.07103C48.1765%20-1.53037%2053.9745%200.442937%2054.0434%205.041L54.4849%2072.2922H9.83113C1.64038%2072.2922%20-2.92775%2062.8321%202.1655%2056.4175L45.317%202.07103Z'%20fill='%233ECF8E'/%3e%3cdefs%3e%3clinearGradient%20id='paint0_linear'%20x1='53.9738'%20y1='54.974'%20x2='94.1635'%20y2='71.8295'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%23249361'/%3e%3cstop%20offset='1'%20stop-color='%233ECF8E'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint1_linear'%20x1='36.1558'%20y1='30.578'%20x2='54.4844'%20y2='65.0806'%20gradientUnits='userSpaceOnUse'%3e%3cstop/%3e%3cstop%20offset='1'%20stop-opacity='0'/%3e%3c/linearGradient%3e%3c/defs%3e%3c/svg%3e)
%20-%20https://sketchapp.com%20--%3e%3ctitle%3eArtboard%3c/title%3e%3cdesc%3eCreated%20with%20Sketch.%3c/desc%3e%3cdefs%3e%3clinearGradient%20x1='50%25'%20y1='0%25'%20x2='50%25'%20y2='99.2583404%25'%20id='linearGradient-1'%3e%3cstop%20stop-color='%232AABEE'%20offset='0%25'%3e%3c/stop%3e%3cstop%20stop-color='%23229ED9'%20offset='100%25'%3e%3c/stop%3e%3c/linearGradient%3e%3c/defs%3e%3cg%20id='Artboard'%20stroke='none'%20stroke-width='1'%20fill='none'%20fill-rule='evenodd'%3e%3ccircle%20id='Oval'%20fill='url(%23linearGradient-1)'%20cx='500'%20cy='500'%20r='500'%3e%3c/circle%3e%3cpath%20d='M226.328419,494.722069%20C372.088573,431.216685%20469.284839,389.350049%20517.917216,369.122161%20C656.772535,311.36743%20685.625481,301.334815%20704.431427,301.003532%20C708.567621,300.93067%20717.815839,301.955743%20723.806446,306.816707%20C728.864797,310.92121%20730.256552,316.46581%20730.922551,320.357329%20C731.588551,324.248848%20732.417879,333.113828%20731.758626,340.040666%20C724.234007,419.102486%20691.675104,610.964674%20675.110982,699.515267%20C668.10208,736.984342%20654.301336,749.547532%20640.940618,750.777006%20C611.904684,753.448938%20589.856115,731.588035%20561.733393,713.153237%20C517.726886,684.306416%20492.866009,666.349181%20450.150074,638.200013%20C400.78442,605.66878%20432.786119,587.789048%20460.919462,558.568563%20C468.282091,550.921423%20596.21508,434.556479%20598.691227,424.000355%20C599.00091,422.680135%20599.288312,417.758981%20596.36474,415.160431%20C593.441168,412.561881%20589.126229,413.450484%20586.012448,414.157198%20C581.598758,415.158943%20511.297793,461.625274%20375.109553,553.556189%20C355.154858,567.258623%20337.080515,573.934908%20320.886524,573.585046%20C303.033948,573.199351%20268.692754,563.490928%20243.163606,555.192408%20C211.851067,545.013936%20186.964484,539.632504%20189.131547,522.346309%20C190.260287,513.342589%20202.659244,504.134509%20226.328419,494.722069%20Z'%20id='Path-3'%20fill='%23FFFFFF'%3e%3c/path%3e%3c/g%3e%3c/svg%3e)
Benefits
Less work between an event and a response
Reduce manual follow-up
Automate data lookups, reports, and notifications so your team can focus on resolving issues quickly.
Build fewer services
Reduce the custom glue code, AWS Lambda functions, and server infrastructure needed for recurring workflows.
Inspect and refine every run
Use structured run records and audit traces to find anomalies and refine how agents respond.
Use cases
Automate workflows for connected devices
Investigate equipment alerts
Compare an alert with recent telemetry and prepare a brief for the operations team.
Detect telemetry anomalies
Monitor device telemetry and publish an alert when a rolling average exceeds a threshold.
Triage offline events
Identify affected devices, review recent messages, and notify the right team.
Enrich device events
Add historical readings and relevant knowledge before forwarding an event to another service.
Summarize operational incidents
When an incident event arrives, query recent telemetry, summarize the context, and send the team a brief.
FAQ
Frequently asked questions
A fully managed service for building and running AI agents on EMQX Cloud. Agents react to MQTT events or handle one-off tasks, using connected data and tools to complete a workflow.
Yes. Agents can publish commands to allowed MQTT topics through a Broker connector. You configure topic permissions and review the workflow before deployment. See MQTT controls.
EMQX Agents manages the underlying LLM. Agents can use EMQX Broker, Tables, and Fleets connectors plus supported external tools, including Snowflake, Teams, and Supabase. View the connector catalog.
Open its run history to inspect status, duration, tool activity, and usage. Each run has a timeline. Refine the behavior in chat and redeploy when needed.
EMQX Agents is available on Google Cloud with the Starter plan. Agents usage is free during Public Beta. Connected EMQX services and external tools may have separate charges. View current availability.