nats_py_async_publish_subscribe_quickstart.py

1import asyncio
2import nats
3from nats.errors import ConnectionClosedError, TimeoutError, NoServersError
4
5async def main():
6    # Connect to NATS
7    nc = await nats.connect("nats://demo.nats.io:4222")
8
9    # Simple publisher and async subscriber
10    sub = await nc.subscribe("updates")
11    
12    # Send a message
13    await nc.publish("updates", b"Hello World")
14
15    # Wait for the message
16    msg = await sub.next_msg()
17    print(f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}")
18
19    # Close NATS connection
20    await nc.close()
21
22if __name__ == '__main__':
23    asyncio.run(main())