open-douyin/db/engine.py

import asyncio
from sqlalchemy.ext.asyncio import AsyncSession, create_async_engine  
from sqlmodel import Field, SQLModel
from config import DB_URL,logger

engine = create_async_engine(DB_URL)  # 替换成你的 DB_URL 
# SQLModel.metadata.create_all() 
async def create_all():  
    async with engine.begin() as conn:  
        await conn.run_sync(SQLModel.metadata.create_all)