aiomqtt 3.0.0a1

The idiomatic asyncio MQTT client

aiomqtt

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("ducks/#", max_qos=aiomqtt.QoS.AT_MOST_ONCE)
    async for message in client.messages():
        print(message.payload)

Key features

• No callbacks! 👍
• Complete MQTTv5 support (flow control, user properties, ...)
• Automatic reconnection
• Fine-grained control over acknowledgments
• Fully type-hinted

Installation

pip install aiomqtt

The only dependency is mqtt5.

Documentation

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.

Contributing

We're happy about contributions! See CONTRIBUTING.md to get started.

Versioning

This project adheres to Semantic Versioning.

Changelog

See CHANGELOG.md, which follows the principles of Keep a Changelog.