异步 SQLite python [关闭]

Question

我使用 aiogram 库编写异步电报机器人。我决定使用 SQLite 作为存储不可变值的数据库。如何从我的数据库中实现异步读取？

Answer 1

sqlite3 模块 already exists 的包装器，您应该在异步代码中使用它。

或者，您可以将同步调用转换为异步调用，方法是将它们包装在 run_in_executor 中。例如：

async def fetchall_async(conn, query):
    loop = asyncio.get_event_loop()
    return await loop.run_in_executor(
        None, lambda: conn.cursor().execute(query).fetchall())

这为您提供了一个可以从异步代码调用的协程，而不必担心长时间运行的执行会阻塞整个事件循环：

async def some_task():
    ...
    students = await fetchall_async(conn, "select * from students")

但最好将它留给经过良好测试的包。