如何从 Quart 获取事件循环

Question

您好，我对 Python 还很陌生，我正在尝试将我在 Flask 上的现有应用程序转换为应该构建在 asyncio 之上的 Quart (https://gitlab.com/pgjones/quart)，因此我可以使用 Goblin OGM 与 JanusGraph 进行交互或 TinkerPop。根据我在 Goblin 上找到的示例，我需要获取一个事件循环来异步运行命令。

    >>> import asyncio
    >>> from goblin import Goblin

    >>> loop = asyncio.get_event_loop()
    >>> app = loop.run_until_complete(
    ...     Goblin.open(loop))
    >>> app.register(Person, Knows)

但是我找不到从 Quart 获取事件循环的方法，即使它是建立在 asyncio 之上的。

有谁知道我怎么能得到它？任何帮助将不胜感激。

Answer 1

TL;DR 要获取事件循环，请调用asyncio.get_event_loop()。

在基于 asyncio 的应用程序中，事件循环通常不属于 Quart 或任何其他协议/应用程序级别的组件，它由 asyncio 或可能的加速器（如 uvloop）提供。事件循环是通过调用asyncio.get_event_loop()获得的，有时用asyncio.set_event_loop()设置。

这是 quart 的 app.run() 用来运行应用程序的，这意味着它可以与 asyncio 为主线程创建的默认事件循环一起使用。在您的情况下，您可以在注册 Goblin 后简单地调用 quart 的 run()：

loop = asyncio.get_event_loop()
goblin_app = loop.run_until_complete(Goblin.open(loop))
goblin_app.register(Person, Knows)
quart_app = Quart(...)
# ... @app.route, etc

# now they both run in the same event loop
quart_app.run()

---

以上应该从实际意义上回答这个问题。但是如果不止一个组件坚持拥有自己的 run() 方法来旋转事件循环，那么这种方法就行不通了——因为 app.run() 不会返回，你只能在线程中调用一个这样的函数。

不过，如果您仔细观察，quart 也并非如此。虽然 Quart 示例确实使用app.run() 为应用程序提供服务，但如果您查看app.run() 的实现，您会看到它调用了便利函数run_app()，它简单地创建了一个服务器并启动了主循环永远：

def run_app(...):
    loop = asyncio.get_event_loop()
    # ...
    create_server = loop.create_server(
        lambda: Server(app, loop, ...), host, port, ...)
    server = loop.run_until_complete(create_server)
    # ...
    loop.run_forever()

如果您需要控制事件循环的实际运行方式，您可以随时自行完成：

# obtain the event loop from asyncio
loop = asyncio.get_event_loop()

# hook Goblin to the loop
goblin_app = loop.run_until_complete(Goblin.open(loop))
goblin_app.register(Person, Knows)

# hook Quart to the loop
quart_server = loop.run_until_complete(loop.create_server(
        lambda: quart.serving.Server(quart_app, loop), host, port))

# actually run the loop (and the program)
try:
    loop.run_forever()
except KeyboardInterrupt:  # pragma: no cover
    pass
finally:
    quart_server.close()
    loop.run_until_complete(quart_server.wait_closed())
    loop.run_until_complete(loop.shutdown_asyncgens())
    loop.close()