这个错误是由于异步操作没有被正确使用所引起的。在使用Alembic进行数据库迁移时,需要在连接数据库时添加asyncio.run()来正确调用异步操作。下面是示例代码:
# 引入asyncio模块
import asyncio
# 在alembic中连接数据库
async def run_migrations_online():
async with alembic_config.connect(url=DATABASE_URL) as conn:
context.configure(connection=conn, target_metadata=target_metadata)
with context.begin_transaction():
context.run_migrations()
# 使用asyncio.run()来运行异步操作
if __name__ == '__main__':
asyncio.run(run_migrations_online())
这样就可以避免RuntimeWarning: coroutine 'connect' was never awaited错误的出现。