This library implements a minimal Python 3 asyncio wrapper around the MQTT client in paho-mqtt.
Installation:
pip install aiomqtt
This library is as thin as possible, exposing the exact same API as the
original paho-mqtt Client object with blocking calls replaced with coroutines
and all callbacks being scheduled into the asyncio main event loop. It does not
attempt to introduce a more idiomatic asyncio API.
When using aiomqtt, refer to the paho-mqtt documentation which applies verbatim with the exception of the above rules. An example use of the library is shown below:
import asyncio
import aiomqtt
loop = asyncio.get_event_loop()
async def demo():
c = aiomqtt.Client(loop)
c.loop_start() # See "About that loop..." below.
connected = asyncio.Event(loop=loop)
def on_connect(client, userdata, flags, rc):
connected.set()
c.on_connect = on_connect
await c.connect("localhost")
await connected.wait()
print("Connected!")
subscribed = asyncio.Event(loop=loop)
def on_subscribe(client, userdata, mid, granted_qos):
subscribed.set()
c.on_subscribe = on_subscribe
c.subscribe("my/test/path")
await subscribed.wait()
print("Subscribed to my/test/path")
def on_message(client, userdata, message):
print("Got message:", message.topic, message.payload)
c.on_message = on_message
message_info = c.publish("my/test/path", "Hello, world")
await message_info.wait_for_publish()
print("Message published!")
await asyncio.sleep(1, loop=loop)
print("Disconnecting...")
disconnected = asyncio.Event(loop=loop)
def on_disconnect(client, userdata, rc):
disconnected.set()
c.on_disconnect = on_disconnect
c.disconnect()
await disconnected.wait()
print("Disconnected")
await c.loop_stop()
print("MQTT loop stopped!")
loop.run_until_complete(demo())Unfortunately the author was unable to work out how to integrate paho-mqtt's event loop into asyncio, despite the best efforts of the paho-mqtt authors to make this possible. (Patches are welcome.)
Instead, loop_start() and loop_stop() may be used as normal (and aiomqtt
will ensure callbacks arrive in the correct thread) or loop_forever() may be
used which in aiomqtt is a coroutine.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent