fastapi连接postgresql并添加数据

FastAPI是一个轻量级的Web框架，而PostgreSQL是一个开源的对象关系型数据库系统。要在FastAPI应用中连接到PostgreSQL并添加数据，你需要遵循几个步骤：

1. **安装必要的库**:
首先，确保你已经安装了`fastapi`、`uvicorn`（用于启动服务器）以及数据库驱动`asyncpg`（适用于异步操作），可以使用`pip`进行安装：

   pip install fastapi uvicorn asyncpg

2. **配置数据库连接**:
在你的项目中创建一个配置文件（例如`main.py`或`config.py`），定义数据库连接参数，如用户名、密码、主机和数据库名：

   from pydantic import BaseSettings

   class Settings(BaseSettings):
       POSTGRES_HOST: str = "localhost"
       POSTGRES_PORT: int = 5432
       POSTGRES_USER: str = "your_username"
       POSTGRES_PASSWORD: str = "your_password"
       POSTGRES_DB: str = "your_database"

   settings = Settings()

3. **使用FastAPI路由处理数据库操作**:
创建一个FastAPI应用并设置路由来处理CRUD（Create, Read, Update, Delete）操作。比如，添加数据的路由可能如下：

   from fastapi import FastAPI, HTTPException, Depends
   import asyncio
   from asyncpg import create_pool

   app = FastAPI()

   # 初始化数据库连接池
   async def get_db():
       db = await create_pool(dsn=f"postgresql://{settings.POSTGRES_USER}:{settings.POSTGRES_PASSWORD}@{settings.POSTGRES_HOST}:{settings.POSTGRES_PORT}/{settings.POSTGRES_DB}")
       return db

   async def add_data(item: dict, db: Pool = Depends(get_db)):
       async with db.acquire() as conn:
           async with conn.transaction():
               await conn.execute("INSERT INTO your_table (column1, column2) VALUES ($1, $2)", item["column1"], item["column2"])
       return {"message": "Data added successfully"}

   @app.post("/add")
   async def add(item: dict):
       try:
           await add_data(item)
           return {"status": "success"}
       except Exception as e:
           raise HTTPException(status_code=500, detail=str(e))

4. **运行应用**:
在`main.py`或`run.py`中启动FastAPI服务，使用`uvicorn`：

   import uvicorn
   from main import app

   uvicorn.run(app, host="0.0.0.0", port=8000)

**相关问题--:**
1. 如何在FastAPI中执行读取操作？
2. 如果想更新已存在的数据，应该怎么做？
3. FastAPI中的错误处理是如何进行的？