夸脱与NATS.io客户端相结合

Question

我试图在一个应用程序中运行夸脱和NATS客户端。将此代码用于nats部件[https://github.com/nats-io/stan.py/issues/12#issuecomment-400865266][1]

我的主要职能包括：

    asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)

    loop.run_until_complete(serve(app, config))
    loop.run_until_complete(run_nats(loop))
    loop.close()

但它只运行夸脱和nats被封锁。我怎么才能解决这个问题？

信息：

• Python 3.9
• 异步nats-客户机0.11.4
• 夸脱0.11.4

Answer 1

loop.run_until_complete线将运行并阻塞，直到它完成，在本例中，运行第一个夸脱(直到它完成)，然后是nats。为了同时运行这两种方式，我通常运行use 聚在，

loop.run_until_complete(asyncio.gather(serve(app, config), run_nats(loop))