在 FastAPI 中实现数据库事务，可以使用 databases 库来操作数据库，并使用 async with 语句来开启和提交事务。以下是一个简单的示例：
from fastapi import FastAPIimport databasesimport asyncioDATABASE_URL = "sqlite:///test.db"database = databases.Database(DATABASE_URL)app = FastAPI()@app.on_event("startup")async def startup(): await database.connect()@app.on_event("shutdown")async def shutdown(): await database.disconnect()@app.post("/create_user")async def create_user(name: str): async with database.transaction(): query = "INSERT INTO users (name) VALUES (:name)" await database.execute(query=query, values={"name": name}) return {"message": "User created successfully"}if __name__ == "__main__": asyncio.run(app.run_server())在上面的示例中，我们首先创建了一个 database 对象来连接数据库。然后在应用启动时通过 startup 事件来连接数据库，在应用关闭时通过 shutdown 事件来断开数据库连接。
在 create_user 路由中，我们使用 async with database.transaction() 来开启一个事务。在事务中，我们执行插入用户数据的 SQL 查询，并通过 database.execute() 来执行查询操作。
通过以上方法，就可以在 FastAPI 中实现数据库事务操作。
