Привет, меня зовут Алексей. Я хочу поделиться с вами своим личным опытом использования FastAPI для создания модели User с использованием библиотеки SQLAlchemy, схем в файле pydantic, функций CRUD и подключения к базе данных Postgres. Я буду рассматривать каждый этап отдельно, включая код для каждого модуля.Для начала, создадим модель User в файле models.py с использованием библиотеки SQLAlchemy. SQLAlchemy предоставляет нам гибкую и удобную работу с базами данных. Вот пример моей модели User⁚
python
from sqlalchemy import Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
Base declarative_base
class User(Base)⁚
__tablename__ ‘users’
id Column(Integer, primary_keyTrue, indexTrue)
name Column(String, indexTrue)
email Column(String, uniqueTrue, indexTrue)
password Column(String)
Далее, мы создадим схему User в файле schemas.py с использованием библиотеки Pydantic. Pydantic позволяет нам определить структуру и валидацию данных. Вот пример моей схемы User⁚
python
from pydantic import BaseModel
class UserCreate(BaseModel)⁚
name⁚ str
email⁚ str
password⁚ str
class UserUpdate(BaseModel)⁚
name⁚ str
email⁚ str
password⁚ str
class User(BaseModel)⁚
id⁚ int
name⁚ str
email⁚ str
class Config⁚
orm_mode True
Теперь, создадим функции CRUD в файле crud.py. CRUD ⎯ это аббревиатура, которая означает ″create″, ″read″, ″update″ и ″delete″. Вот пример моих функций CRUD для модели User⁚
python
from sqlalchemy.orm import Session
from . import models, schemas
def create_user(db⁚ Session, user⁚ schemas.UserCreate)⁚
db_user models.User(nameuser.name, emailuser.email, passworduser.password)
db;add(db_user)
db.commit
db.refresh(db_user)
return db_user
def get_user(db⁚ Session, user_id⁚ int)⁚
return db.query(models.User).filter(models.User.id user_id).first
def get_users(db⁚ Session, skip⁚ int 0, limit⁚ int 100)⁚
return db.query(models.User).offset(skip).limit(limit).all
def update_user(db⁚ Session, user⁚ schemas.UserUpdate)⁚
db_user db.query(models.User).filter(models.User.id user.id).first
db_user.name user.name
db_user.email user.email
db.commit
db.refresh(db_user)
return db_user
def delete_user(db⁚ Session, user_id⁚ int)⁚
db_user db.query(models.User).filter(models.User.id user_id).first
db.delete(db_user)
db.commit
Наконец, создадим эндпоинты для модели User в файле views.py, используя схемы из файла schemas.py и функции CRUD из файла crud.py. Вот пример моих эндпоинтов⁚
python
from fastapi import Depends, FastAPI, HTTPException
from sqlalchemy.orm import Session
from . import crud, models, schemas
from .database import SessionLocal, engine
app FastAPI
models.Base.metadata.create_all(bindengine)
def get_db⁚
db SessionLocal
try⁚
yield db
finally⁚
db.close
@app.post(″/users/», response_modelschemas.User)
def create_user(user⁚ schemas.UserCreate, db⁚ Session Depends(get_db))⁚
db_user crud.get_user_by_email(db, emailuser.email)
if db_user⁚
raise HTTPException(status_code400, detail″Email already registered″)
return crud.create_user(dbdb, useruser)
@app.get(″/users/{user_id}», response_modelschemas.User)
def read_user(user_id⁚ int, db⁚ Session Depends(get_db))⁚
db_user crud.get_user(db, user_iduser_id)
if db_user is None⁚
raise HTTPException(status_code404, detail″User not found″)
return db_user
@app.get(″/users/», response_modelList[schemas.User])
def read_users(skip⁚ int 0, limit⁚ int 100, db⁚ Session Depends(get_db))⁚
users crud.get_users(db, skipskip, limitlimit)
return users
@app.put(″/users/{user_id}», response_modelschemas.User)
def update_user(user_id⁚ int, user⁚ schemas.UserUpdate, db⁚ Session Depends(get_db))⁚
db_user crud.get_user(db, user_iduser_id)
if db_user is None⁚
raise HTTPException(status_code404, detail″User not found″)
return crud.update_user(dbdb, useruser)
@app.delete(″/users/{user_id}», response_modelschemas.User)
def delete_user(user_id⁚ int, db⁚ Session Depends(get_db))⁚
db_user crud.get_user(db, user_iduser_id)
if db_user is None⁚
raise HTTPException(status_code404, detail″User not found″)
crud.delete_user(dbdb, user_iduser_id)
return db_user
Наконец, мы можем подключиться к базе данных Postgres, чтобы запустить наши эндпоинты; Для этого, нам нужно создать файл database.py⁚
python
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
SQLALCHEMY_DATABASE_URL ″postgresql://user:password@localhost/database»
engine create_engine(SQLALCHEMY_DATABASE_URL)
SessionLocal sessionmaker(autocommitFalse, autoflushFalse, bindengine)
Это основная структура кода, которую вы можете использовать, чтобы создать модель User с использованием FastAPI, SQLAlchemy, Pydantic и базы данных Postgres. Я надеюсь, что этот опыт поможет вам начать разрабатывать свое собственное веб-приложение! Удачи!