asyncio-mqtt

import asyncio from asyncio_mqtt import Client, MqttError async def publish_message(): async with Client("test.mosquitto.org") as client: await client.publish("my/topic", payload=b"Hello, asyncio-mqtt!") print("Published 'Hello, asyncio-mqtt!' to my/topic") async def subscribe_and_receive(): async with Client("test.mosquitto.org") as client: async with client.filtered_messages("my/topic") as messages: await client.subscribe("my/topic") print("Subscribed to my/topic. Waiting for messages...") async for message in messages: print(f"Received: {message.payload.decode()} on topic {message.topic}") # For quickstart, exit after one message break async def main(): await asyncio.gather(publish_message(), subscribe_and_receive()) if __name__ == "__main__": # Note for Windows users: Since Python 3.8, the default asyncio event loop is the # ProactorEventLoop. It doesn't support the add_reader method required by asyncio-mqtt. # Switch to SelectorEventLoop if encountering issues. # import sys # if sys.platform.lower() == "win32" or os.name.lower() == "nt": # from asyncio import set_event_loop_policy, WindowsSelectorEventLoopPolicy # set_event_loop_policy(WindowsSelectorEventLoopPolicy()) asyncio.run(main())