nats_py_async_connect_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 subscriber
10    sub = await nc.subscribe("updates")
11    await nc.publish("updates", b'All is Well')
12
13    # Wait for the message
14    msg = await sub.next_msg()
15    print(f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}")
16
17    # Close NATS connection
18    await nc.close()
19
20if __name__ == '__main__':
21    asyncio.run(main())