Note
aiomqtt v3 is released! It switches the underlying protocol library from paho-mqtt to the sans-io mqtt5 library. This means aiomqtt is now pure asyncio (no more threads). Try it with pip install aiomqtt==3.0.0-alpha.1.
The idiomatic asyncio MQTT client. Write code like this:
Publish
async with aiomqtt.Client(hostname="test.mosquitto.org") as client:
await client.publish("ducks/louie/status", b"quack")Subscribe
async with aiomqtt.Client(hostname="test.mosquitto.org") as client:
await client.subscribe(
aiomqtt.TopicFilter("ducks/#"), max_qos=aiomqtt.QoS.AT_MOST_ONCE,
)
async for message in client.messages():
print(message.payload)- No callbacks! 👍
- Complete MQTTv5 support (backpressure, user properties, ...)
- Automatic reconnection
- Fine-grained control over acknowledgments
- Pure asyncio
- Fully type-hinted
pip install aiomqtt
The only dependency is mqtt5.
To get started, see the guides.
If you're new to MQTT, we recommend reading HiveMQ's MQTT essentials as an introduction. Afterward, the MQTTv5 specification is a great reference.
The RealPython walkthrough is a nice introduction to Python's asyncio.
We're happy about contributions! See CONTRIBUTING.md to get started.
This project adheres to Semantic Versioning.
See CHANGELOG.md, which follows the principles of Keep a Changelog.