在使用async SQLAlchemy时,需要使用异步驱动程序来创建引擎。下面是示例代码:
# 导入所需的库
import asyncio
from aiomysql.sa import create_engine
async def main():
# 设置数据库的连接信息
db_user = 'user'
db_pass = 'password'
db_name = 'database_name'
db_host = 'localhost'
db_port = 3306
# 创建异步引擎
engine = await create_engine(
user=db_user,
password=db_pass,
db=db_name,
host=db_host,
port=db_port,
minsize=1,
maxsize=10
)
# 使用引擎进行查询操作,这里以查询users表的所有记录为例
async with engine.acquire() as conn:
results = await conn.execute("SELECT * FROM users")
async for row in results:
print(row)
# 关闭引擎
engine.close()
await engine.wait_closed()
# 运行main函数
asyncio.run(main())
这样就可以使用async SQLAlchemy创建引擎了。需要注意的是,在异步环境下使用SQLAlchemy,需要使用支持异步操作的第三方包,如aiomysql。