aiomqtt_async_publish_subscribe_with_wildcard_topic.py

1import asyncio
2import aiomqtt
3
4async def main():
5    async with aiomqtt.Client("test.mosquitto.org") as client:
6        # Publish a message
7        await client.publish("humidity/outside", payload=0.38)
8
9        # Subscribe to a topic and iterate over incoming messages
10        async with client.messages() as messages:
11            await client.subscribe("humidity/#")
12            async for message in messages:
13                print(message.payload.decode())
14
15asyncio.run(main())