异步 SQLAlchemy 教程

异步 SQLAlchemy 是一个让 Python 应用程序以异步方式操作数据库的库。它允许你在处理大量数据库操作时保持应用的响应性。

快速概览

• 使用异步 SQLAlchemy 可以提高应用程序的 I/O 效率。
• 异步操作意味着可以在等待数据库响应时执行其他任务。

安装

pip install asyncpg sqlalchemy

使用示例

以下是一个简单的示例，展示如何使用异步 SQLAlchemy 连接到数据库并执行查询：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
import asyncpg

async def main():
    # 创建异步连接引擎
    engine = create_engine('postgresql+asyncpg://user:password@localhost/dbname')

    # 创建异步会话
    async with engine.begin() as connection:
        # 执行异步查询
        record = await connection.fetchrow('SELECT * FROM my_table WHERE id = $1', 1)
        print(record)

# 运行异步主函数
import asyncio
asyncio.run(main())

扩展阅读

• SQLAlchemy 官方文档
• 异步编程指南

图片