如何在Python中订阅NATS主题并不断接收消息？

import asyncio
from nats.aio.client import Client as NATS

nc = NATS()

await nc.connect(servers=["nats://your-nats-server-url:4222"])

async def message_handler(msg):
    subject = msg.subject
    data = msg.data.decode()
    print(f"Received a message on '{subject}': {data}")

await nc.subscribe("your-subject", cb=message_handler)

await nc.flush()
await asyncio.get_event_loop().run_forever()

import asyncio
from nats.aio.client import Client as NATS

async def message_handler(msg):
    subject = msg.subject
    data = msg.data.decode()
    print(f"Received a message on '{subject}': {data}")

async def main():
    nc = NATS()
    await nc.connect(servers=["nats://your-nats-server-url:4222"])
    await nc.subscribe("your-subject", cb=message_handler)
    await nc.flush()
    await asyncio.get_event_loop().run_forever()

if __name__ == '__main__':
    asyncio.run(main())