mongodb - 使用电机连接 MongoDB 时，Asyncio (Quart) 引发附加到不同循环的任务错误

Question

我已经使用 MongoDB 和 Motor.Asyncio 使用 Quart 创建了一个 Web 应用程序。 当应用程序尝试查询数据库时，会抛出错误:

Task <Task pending coro=<ASGIHTTPConnection.handle_request() 
running at /home/user/.local/lib/python3.7/site-packages/quart
/asgi.py:59> cb=[_wait.<locals>._on_completion() at /usr/lib/python3.7
/asyncio/tasks.py:440]> got Future <Future pending cb=[run_on_executor.
<locals>._call_check_cancel() at /home/user/.local/lib/python3.7/site-
packages/motor/frameworks/asyncio/__init__.py:80]> attached to a 
different loop

我不明白为什么会发生这种情况，也不知道如何解决。

该应用程序一直运行没有问题，但我决定从 Python 3.6(在 Ubuntu-18.04 上)升级到 python 3.7.1。这样我将 Quart 升级到了 0.9.0。由于此升级，出现了上述错误。

该应用程序使用 Hypercorn 和 Nginx 从命令行运行。

我不确定我的代码的哪些部分与这种情况相关

我先导入夸脱，然后导入电机:

    # Mongodb / Gridfs with Motor
    import motor.motor_asyncio
    from pymongo import ReturnDocument
    from bson.objectid import ObjectId
    from bson.son import SON

    client = motor.motor_asyncio.AsyncIOMotorClient()
    db = client.myDataBase
    fs = motor.motor_asyncio.AsyncIOMotorGridFSBucket(db)

在此之后我添加:

    app = Quart(__name__)

我尝试在电机导入 block 之前移动它，但它没有任何改变。

正如问题/答案中所建议的: RuntimeError: Task attached to a different loop 我补充道:

    loop=asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    client = motor.motor_asyncio.AsyncIOMotorClient(io_loop=loop)

这并没有解决问题。

这是第一次调用 motor 的 block ，也是发生错误的地方:

    try:
        session_info = await db.sessions.find_one(
            {
                'session_id': uuid.UUID(session_id)
            },
            {
                'username':True,
                '_id':False
            }
        )
    except Exception as e:
        print('error retrieving session info:', e)

我可以忽略该错误并继续，但随后进行下一个调用并发生相同的错误。

据我所知，Quart 在默认的 event_loop 上工作，不需要为电机创建特殊的循环。在以前的版本中无需它即可工作。所以我完全不知所措。

Answer 1

我根据这个问题找到了解决方案: asyncio.run fails when loop.run_until_complete works

那里提供的答案建议将 mongoDB 的初始化移到 main() 内部。在这种特定情况下，因为这是一个 Quart 应用程序，所以本身没有主应用程序。但直觉依然存在。

我在模块级别定义了一个初始化函数，然后在调用数据库之前我检查它是否已经初始化，如果没有，我调用初始化函数。

    import motor.motor_asyncio
    from pymongo import ReturnDocument
    from bson.objectid import ObjectId
    from bson.son import SON

    client = None
    db = None
    fs = None

    async def connect_to_mongo():
        global client, db, fs
        client = motor.motor_asyncio.AsyncIOMotorClient()
        db = client.myDataBase
        fs = motor.motor_asyncio.AsyncIOMotorGridFSBucket(db)

然后在调用数据库之前:

    if db is None:
        await connect_to_mongo()

这解决了我的问题。为什么我的代码在升级之前可以工作？我不知道。