fastzdp_login的第一次构建

概述

为了方便能够快捷的实现fastapi实现登录相关功能代码开发，决定开发一个开源的fastapi组件库，想了很多个名字，在检查pypi的时候发现都被占用了，所以最终决定使用fastzdp_login这个名字。
fast代表的时fastapi。zdp代表的是张大鹏。login代表的是登录功能。
希望通过fastzdp_login这个库，能够简化使用fastapi开发登录功能的逻辑，实现低代码低成本的开发。

环境搭建

首先是安装基本依赖：

pip install poetry 
poetry add fastapi

fastapi底层依赖特别多，所以安装特别慢，不信你看：
在这里插入图片描述

而我们的zdppy_api框架则是零依赖的，安装速度特别快。所以，如果你zdppy_api和fastapi都会的话，建议你优先使用zdppy_api这个框架。
这里之所以开发fastapi的组件库并开源，主要是为了方便在工作中使用fastapi作为核心框架的同学。

接着，还需要安装操作MySQL数据库的依赖：

poetry add sqlmodel[mysql]

在这里插入图片描述

最后，是我们启动服务的依赖：

poetry add uvicorn

配置pip国内源：

pip config set global.index-url https://pypi.tuna.tsinghua.edu.cn/simple

配置poetry国内源：

poetry source add --priority=default mirrors https://pypi.tuna.tsinghua.edu.cn/simple/

用户增删改查示例

from fastapi import FastAPI, Depends, HTTPException, status
from sqlalchemy.orm import Session as SASession
from sqlmodel import SQLModel, Field, Session, create_engine, select
from typing import Optionalclass User(SQLModel, table=True):id: Optional[int] = Field(default=None, primary_key=True)username: str = Field(index=True)password: stremail: strphone: stravatar: strname: str# 创建数据库引擎
sqlite_url = "mysql+pymysql://root:zhangdapeng520@127.0.0.1:3306/zdppy_demo?charset=utf8mb4"
engine = create_engine(sqlite_url, echo=True)# 确保表存在
SQLModel.metadata.create_all(engine)app = FastAPI()# 依赖项，为每个请求提供数据库会话
def get_db():db = Session(engine)try:yield dbfinally:db.close()@app.post("/users/", response_model=User)
def create_user(user: User, db: SASession = Depends(get_db)):db.add(user)db.commit()db.refresh(user)return user# 读取所有用户
@app.get("/users/", response_model=list[User])
def read_users(db: SASession = Depends(get_db)):return db.exec(select(User)).all()# 读取单个用户
@app.get("/users/{user_id}", response_model=User)
def read_user(user_id: int, db: SASession = Depends(get_db)):user = db.get(User, user_id)if not user:raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="User not found")return user# 更新用户
@app.put("/users/{user_id}", response_model=User)
def update_user(user_id: int, user: User, db: SASession = Depends(get_db)):db_user = db.get(User, user_id)if not db_user:raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="User not found")for field in user.__fields__:if getattr(user, field.name, None) is not None:setattr(db_user, field.name, getattr(user, field.name))db.commit()db.refresh(db_user)return db_user# 删除用户
@app.delete("/users/{user_id}", status_code=status.HTTP_204_NO_CONTENT)
def delete_user(user_id: int, db: SASession = Depends(get_db)):db_user = db.get(User, user_id)if db_user is None:raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="User not found")db.delete(db_user)db.commit()return Noneif __name__ == '__main__':import uvicornuvicorn.run(app, host='0.0.0.0', port=8000)

开发注册接口

from fastapi import FastAPI, Depends, HTTPException, status, Body
from sqlalchemy.orm import Session as SASession
from sqlmodel import SQLModel, Field, Session, create_engine, select
from typing import Optional
from passlib.hash import pbkdf2_sha256 as sha256  # 用于密码哈希class User(SQLModel, table=True):id: Optional[int] = Field(default=None, primary_key=True)username: str = Field(index=True)password: str# 创建数据库引擎
sqlite_url = "mysql+pymysql://root:zhangdapeng520@127.0.0.1:3306/zdppy_demo?charset=utf8mb4"
engine = create_engine(sqlite_url, echo=True)# 确保表存在
SQLModel.metadata.drop_all(engine)
SQLModel.metadata.create_all(engine)app = FastAPI()# 依赖项，为每个请求提供数据库会话
def get_db():db = Session(engine)try:yield dbfinally:db.close()@app.post("/users/register/", status_code=status.HTTP_201_CREATED)
def register_user(username: str = Body(str, min_length=2, max_length=36),password: str = Body(str, min_length=6, max_length=128),db: SASession = Depends(get_db),
):# 检查用户名是否已存在user = db.exec(select(User).where(User.username == username)).first()if user:raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Username already exists")# 对密码进行哈希处理hashed_password = sha256.hash(password)# 创建新用户new_user = User(username=username, password=hashed_password)db.add(new_user)try:db.commit()db.refresh(new_user)except Exception as e:print(e)db.rollback()raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Operation failed")return {"message": "User registered successfully", "user_id": new_user.id}

实现登录接口

import timefrom fastapi import FastAPI, Depends, HTTPException, status, Body
from sqlalchemy.orm import Session as SASession
from sqlmodel import SQLModel, Field, Session, create_engine, select
from typing import Optional
from passlib.hash import pbkdf2_sha256 as sha256  # 用于密码哈希
from jwt import encode as jwt_encode
from fastapi.security import OAuth2PasswordBearer, OAuth2PasswordRequestFormclass User(SQLModel, table=True):id: Optional[int] = Field(default=None, primary_key=True)username: str = Field(index=True)password: str# 创建数据库引擎
sqlite_url = "mysql+pymysql://root:zhangdapeng520@127.0.0.1:3306/zdppy_demo?charset=utf8mb4"
engine = create_engine(sqlite_url, echo=True)# 确保表存在
SQLModel.metadata.drop_all(engine)
SQLModel.metadata.create_all(engine)app = FastAPI()# 创建一个 OAuth2 令牌
oauth2_scheme = OAuth2PasswordBearer(tokenUrl="token")# 伪造一个密钥，实际使用时应该使用安全的方式存储
SECRET_KEY = "your-secret-key"
ALGORITHM = "HS256"# 令牌有效期
ACCESS_TOKEN_EXPIRE_MINUTES = 30# 假设你有一个获取用户的函数
def get_user(db: SASession, username: str):return db.exec(select(User).where(User.username == username)).first()# 依赖项，为每个请求提供数据库会话
def get_db():db = Session(engine)try:yield dbfinally:db.close()@app.post("/users/register/", status_code=status.HTTP_201_CREATED)
def register_user(username: str = Body(str, min_length=2, max_length=36),password: str = Body(str, min_length=6, max_length=128),db: SASession = Depends(get_db),
):# 检查用户名是否已存在user = db.exec(select(User).where(User.username == username)).first()if user:raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Username already exists")# 对密码进行哈希处理hashed_password = sha256.hash(password)# 创建新用户new_user = User(username=username, password=hashed_password)db.add(new_user)try:db.commit()db.refresh(new_user)except Exception as e:print(e)db.rollback()raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Operation failed")return {"message": "User registered successfully", "user_id": new_user.id}# 登录接口
@app.post("/token/", response_model=dict, status_code=status.HTTP_200_OK)
async def login_for_access_token(form_data: OAuth2PasswordRequestForm = Depends(), db: SASession = Depends(get_db)):user = get_user(db, form_data.username)if not user:raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Incorrect username or password")if not sha256.verify(form_data.password, user.password):raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Incorrect username or password")access_token = jwt_encode({"username": user.username, "id": user.id, "time": time.time(), "expired": ACCESS_TOKEN_EXPIRE_MINUTES * 60},SECRET_KEY,algorithm=ALGORITHM,).encode("utf-8")return {"access_token": access_token, "token_type": "bearer"}if __name__ == '__main__':import uvicornuvicorn.run(app, host='0.0.0.0', port=8000)

后续

后面根据这两个原型接口进行改造。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/364640.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

“ONLYOFFICE 8.1：提升用户体验和编辑功能的全面升级”

“ONLYOFFICE 8.1：提升用户体验和编辑功能的全面升级”

引言 官网链接 在当今快节奏的工作环境中，高效地处理文档是每个职场人士必备的技能。ONLYOFFICE 桌面编辑器凭借其强大的功能和用户友好的界面，成为了提升文档处理效率的得力助手。本文将介绍 ONLYOFFICE 桌面编辑器的核心特性，并展示如何通…
阅读更多...
Zynq7000系列FPGA中的DMA控制器简介（二）

Zynq7000系列FPGA中的DMA控制器简介（二）

AXI互连上的DMA传输 所有DMA事务都使用AXI接口在PL中的片上存储器、DDR存储器和从外设之间传递数据。PL中的从设备通过DMAC的外部请求接口与DMAC通信，以控制数据流。这意味着从设备可以请求DMA交易，以便将数据从源地址传输到目标地址。 虽然DMAC在技术…
阅读更多...
pdf合并，pdf合并成一个pdf，pdf合并在线网页版

pdf合并，pdf合并成一个pdf，pdf合并在线网页版

在处理pdf文件的过程中，有时我们需要将多个pdf文件合并成一个pdf文件。作为一名有着丰富计算机应用经验的技术博主，我将为您详细介绍如何将多个pdf文件合并成一个pdf文件。 pdf合并方法：使用， “轻云处理pdf官网” 打开 “轻云处…
阅读更多...
ChatGPT智能对话绘画系统 带完整的安装源代码包以及搭建教程

ChatGPT智能对话绘画系统 带完整的安装源代码包以及搭建教程

系统概述 ChatGPT 智能对话绘画系统是一款集智能语言处理和绘画创作于一体的综合性系统。它利用了深度学习和自然语言处理技术，能够理解用户的意图和需求，并通过与用户的交互，生成富有创意的绘画作品。该系统的核心是一个强大的人工智能模型…
阅读更多...
C#基于SkiaSharp实现印章管理（3）

C#基于SkiaSharp实现印章管理（3）

本系列第一篇文章中创建的基本框架限定了印章形状为矩形，但常用的印章有方形、圆形等多种形状，本文调整程序以支持定义并显示矩形、圆角矩形、圆形、椭圆等4种形式的印章背景形状。   定义印章背景形状枚举类型，矩形、圆形、椭圆相关的尺寸…
阅读更多...
QT事件处理及实例（鼠标事件、键盘事件、事件过滤）

QT事件处理及实例（鼠标事件、键盘事件、事件过滤）

这篇文章通过鼠标事件、键盘事件和事件过滤的三个实例介绍事件处理的实现。 鼠标事件及实例 鼠标事件包括鼠标的移动、按下、松开、单击和双击等。 创建一个MouseEvent项目，通过项目介绍如何获得和处理鼠标事件。程序效果如下图所示。 界面布局代码如下&#xff…
阅读更多...
Python数据分析-风湿关节炎生存分析

Python数据分析-风湿关节炎生存分析

一、研究背景和意义 类风湿关节炎（RA）是一种慢性炎症性疾病，主要影响关节，但也可能影响身体的其他部分。RA的病因尚不完全清楚，但已知其涉及免疫系统的异常反应。患者的免疫系统错误地攻击自身的关节组织，…
阅读更多...
STM32音频应用开发：DMA与定时器的高效协作

STM32音频应用开发：DMA与定时器的高效协作

摘要: 本文章将深入浅出地介绍如何使用STM32单片机实现音频播放功能。文章将从音频基础知识入手，逐步讲解音频解码、DAC转换、音频放大等关键环节，并结合STM32 HAL库给出具体的代码实现和电路设计方案。最后，我们将通过一个实例演示如何播放W…
阅读更多...
Maven的依赖传递、依赖管理、依赖作用域

Maven的依赖传递、依赖管理、依赖作用域

在Maven项目中通常会引入大量依赖，但依赖管理不当，会造成版本混乱冲突或者目标包臃肿。因此，我们以SpringBoot为例，从三方面探索依赖的使用规则。 1、 依赖传递 依赖是会传递的，依赖的依赖也会连带引入。例如在项目中…
阅读更多...
云计算【第一阶段（21）】Linux引导过程与服务控制

云计算【第一阶段（21）】Linux引导过程与服务控制

目录 一、linux操作系统引导过程 1.1、开机自检 1.2、MBR引导 1.3、GRUB菜单 1.4、加载 Linux 内核 1.5、init进程初始化 1.6、简述总结 1.7、初始化进程centos 6和7的区别 二、排除启动类故障 2.1、修复MBR扇区故障 2.1.1、 实验 2.2、修复grub引导故障 2.2.1、实…
阅读更多...
红队内网攻防渗透：内网渗透之内网对抗：横向移动篇Kerberos委派安全RBCD资源Operators组成员HTLMRelay结合

红队内网攻防渗透：内网渗透之内网对抗：横向移动篇Kerberos委派安全RBCD资源Operators组成员HTLMRelay结合

红队内网攻防渗透 1. 内网横向移动1.1 横向移动-资源约束委派-利用域用户主机加入1.1.1 利用思路1.1.2 利用条件1.1.3 利用过程1.2 横向移动-资源约束委派-Acount Operators组1.2.1 利用思路：1.2.2 利用条件：1.2.3 利用过程：1.3 横向移动-资源约束委派-CVE结合HTLMRelay1.3.…
阅读更多...
哥斯拉短视频：成都柏煜文化传媒有限公司

哥斯拉短视频：成都柏煜文化传媒有限公司

哥斯拉短视频：巨兽传奇的视听盛宴 在短视频的海洋中，成都柏煜文化传媒有限公司 有一种特殊的存在总能吸引人们的目光，那就是以哥斯拉为主题的短视频。这些视频以震撼的视觉效果、扣人 ​心弦的剧情和独特的怪兽文化，为我们呈现了…
阅读更多...
SHELL脚本学习（十二）sed进阶

SHELL脚本学习（十二）sed进阶

一、多行命令 概述 sed 编辑器的基础命令都是对一行文本进行操作。如果要处理的数据分布在多行中，sed基础命令是没办法处理的。 幸运的是，sed编辑器的设计人员已经考虑了这个问题的解决方案。sed编辑器提供了3个处理多行文本的特殊命令。 命令描述N加…
阅读更多...
NPOI入门指南：轻松操作Excel文件的.NET库

NPOI入门指南：轻松操作Excel文件的.NET库

目录 引言 一、NPOI概述 二、NPOI的主要用途 三、安装NPOI库 四、NPOI基本使用 六、性能优化和内存管理 七、常见问题与解决方案 八、结论 附录 引言 Excel文件作为数据处理的重要工具，广泛应用于各种场景。然而，在没有安装Microsoft Office的…
阅读更多...
PySide(PyQt)在图像上画线

PySide(PyQt)在图像上画线

1、按鼠标左键任意画线 import sys from PySide6.QtWidgets import QApplication, QLabel, QVBoxLayout, QWidget from PySide6.QtGui import QPainter, QPixmap, QMouseEvent, QColor, QPen from PySide6.QtCore import Qt, QPointclass PaintLabel(QLabel):def __init__(self…
阅读更多...
本教程将指导如何通过 Vue 组件和后端 API 交互

本教程将指导如何通过 Vue 组件和后端 API 交互

本人详解 作者：王文峰，参加过 CSDN 2020年度博客之星，《Java王大师王天师》 公众号：JAVA开发王大师，专注于天道酬勤的 Java 开发问题中国国学、传统文化和代码爱好者的程序人生，期待你的关注和支持！本人外号：神秘小峯 山峯 转载说明：务必注明来源（注明：作者：王文峰…
阅读更多...
Redis 集群模式

Redis 集群模式

一、集群模式概述 Redis 中哨兵模式虽然提高了系统的可用性，但是真正存储数据的还是主节点和从节点，并且每个节点都存储了全量的数据，此时，如果数据量过大，接近或超出了 主节点 / 从节点机器的物理内存，就…
阅读更多...
【Python系列】列表推导式：简洁而强大的数据操作工具

【Python系列】列表推导式：简洁而强大的数据操作工具

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…
阅读更多...
洛谷 P1548 [NOIP1997 普及组] 棋盘问题

洛谷 P1548 [NOIP1997 普及组] 棋盘问题

题目 洛谷 P1548 [NOIP1997 普及组] 棋盘问题 [NOIP1997 普及组] 棋盘问题 题目背景 NOIP1997 普及组第一题 题目描述 设有一个 N M N \times M NM 方格的棋盘 ( 1 ≤ N ≤ 100 , 1 ≤ M ≤ 100 ) (1≤N≤100,1≤M≤100) (1≤N≤100,1≤M≤100) 求出该棋盘中包含有多少个正…
阅读更多...
【Hadoop学习笔记】认识Hadoop

【Hadoop学习笔记】认识Hadoop

认识Hadoop 从网上找的课程做的笔记，有些图是自己理解画的，可能不正确，可以作为参考，有疑问的地方请直接指出，共同交流。 Hadoop是由Apache基金会开发的一个分布式系统基础架构，主要解决海量数据的存储和海…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023