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.mzph.cn/bicheng/40774.shtml

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

相关文章

Springboot与xxl-job

Springboot与xxl-job

一、下载xxl-job项目 XXL-JOB是一个分布式任务调度平台，其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线，开箱即用。 从GitHub上面将项目clone下来，如果网络问题导致速度慢也可以从Gitee上面拉…
阅读更多...
JavaScript中的立即执行函数表达式（Immediately Invoked Function Expression, IIFE）

JavaScript中的立即执行函数表达式（Immediately Invoked Function Expression, IIFE）

聚沙成塔每天进步一点点 本文回顾 ⭐ 专栏简介JavaScript中的立即执行函数表达式（Immediately Invoked Function Expression, IIFE）1. 引言2. IIFE的概念2.1 概述2.2 语法2.3 历史背景 3. IIFE的作用3.1 创建独立作用域3.2 模块化代码3.3 防止变量提升3.…
阅读更多...
SAPUI5基础知识10 - i18与国际化

SAPUI5基础知识10 - i18与国际化

1. 背景 i18n 是 “internationalization” 的缩写，其中的 18 是 “internationalization” 这个单词中间的字符数。i18n 是一种让应用程序支持多种语言的方法，也就是我们通常所说的国际化。 在SAPUI5中，i18n主要通过使用资源模型&#xff…
阅读更多...
跑腿平台小程序的设计

跑腿平台小程序的设计

管理员账户功能包括：系统首页，个人中心，基础数据管理，管理员管理，接单详情管理，跑腿员管理，跑腿任务管理 微信端账号功能包括：系统首页，跑腿任务，接单员&…
阅读更多...
RocketMQ源码学习笔记：Producer启动流程

RocketMQ源码学习笔记：Producer启动流程

这是本人学习的总结，主要学习资料如下 马士兵教育rocketMq官方文档 目录 1、Overview1.1、创建MQClientInstance1.1.1、检查1.1.1、MQClientInstance的ID 1.2、MQClientInstance.start() 1、Overview 这是发送信息的代码样例， DefaultMQProducer produ…
阅读更多...
Gradio 教程四：Building Generative AI Applications with Gradio

Gradio 教程四：Building Generative AI Applications with Gradio

文章目录 一、使用interface构建NLP应用1.1 构建文本摘要应用1.1.1 设置API密钥1.1.2 调用文本摘要API1.1.3 运行本地模型获取响应1.1.4 使用interface构建应用 1.2 构建命名实体识别应用1.2.1 调用NER任务API1.2.2 使用interface构建应用1.2.3 加入额外函数，合并to…
阅读更多...
CPU/内存/综合性能评估工具汇总-3:unixbench

CPU/内存/综合性能评估工具汇总-3:unixbench

目录 一、概括二、UnixBench 一、概括 嵌入式开发中对要设计的产品、立项的项目进行设计时，往往需要对关键芯片进行性能评估，本文主要总结基于linux系统的产品在性能评估时的工具使用总结，在aarch64(arm64平台下测试)，板卡根文件…
阅读更多...
Rhino 犀牛三维建模工具下载安装，Rhino 适用于机械设计广泛领域

Rhino 犀牛三维建模工具下载安装，Rhino 适用于机械设计广泛领域

Rhinoceros，这款软件小巧而强大，无论是机械设计、科学工业还是三维动画等多元化领域，它都能展现出其惊人的建模能力。 Rhinoceros所包含的NURBS建模功能，堪称业界翘楚。NURBS，即非均匀有理B样条，是计算机图…
阅读更多...
【笔记】记录一次全新的Java项目部署过程

【笔记】记录一次全新的Java项目部署过程

记录一次全新的Java项目部署过程 环境：CentOS7 一、初始环境准备 yum install wget -y yum install vim -y yum install net-tools -y mkdir /data mkdir /data/html mkdir /data/backend一、安装JDK 17 安装JDK17 # 下载rpm wget https://download.oracle.com…
阅读更多...
数据驱动：Facebook的广告策略与商业模式

数据驱动：Facebook的广告策略与商业模式

在现代数字经济中，数据已经成为新的石油，驱动着企业的增长和创新。Facebook，作为全球最大的社交媒体平台之一，充分利用其庞大的用户数据和先进的算法技术，建立了一个高度精确和高效的广告生态系统。这不仅推动了平台自…
阅读更多...
带着味蕾去旅行，在“必吃”餐厅里认识一座城

带着味蕾去旅行，在“必吃”餐厅里认识一座城

时代不同了，旅游也变了。十多年前的旅游，是文艺青年的诗与远方，生活在别处的荷尔蒙之旅，宁浩拍了部电影叫《心花怒放》，那些年不管是大理、丽江、拉萨、成都，还是张家界，商家最喜欢用的宣传口号…
阅读更多...
Oracle Database 23ai新特性：DB_DEVELOPER_ROLE角色

Oracle Database 23ai新特性：DB_DEVELOPER_ROLE角色

角色介绍 从 Oracle Database 23ai 开始，新角色“DB_DEVELOPER_ROLE”允许管理员快速分配开发人员为 Oracle 数据库设计、构建和部署应用程序所需的所有必要权限。（包括构建数据模型所需的系统权限以及监视和调试应用程序所需的对象权限）。通…
阅读更多...
NSSCTF-Web题目23(RCE-空格绕过)

NSSCTF-Web题目23(RCE-空格绕过)

目录 [SWPUCTF 2022 新生赛]webdog1__start 1、题目 2、知识点 3、思路 [FSCTF 2023]webshell是啥捏 4、题目 5、知识点 6、思路 [SWPUCTF 2022 新生赛]webdog1__start 1、题目 2、知识点 RCE、空格绕过，嵌套eval 3、思路 出现这个页面，没有其…
阅读更多...
【SSL 1056】最大子矩阵 (多维DP)

【SSL 1056】最大子矩阵 (多维DP)

题目大意 已知矩阵的大小定义为矩阵中所有元素的和。给定一个矩阵，你的任务是找到最大的非空（大小至少是 1 ∗ 1 1*1 1∗1）子矩阵。 比如，如下 4 ∗ 4 4*4 4∗4 子矩阵 0 -2 -7 0 9 2 -6 2 -4 1 -4 1 -1 8 0 -2 的最大子矩阵是 …
阅读更多...
组件丰富、支持2/3D数据可视化的编辑器平台软件？

组件丰富、支持2/3D数据可视化的编辑器平台软件？

数据可视化编辑器通常用于创建交互式的图表和模型，可以帮助用户以更直观的方式展示数据。一些在线平台软件提供了丰富的组件，支持2D和3D数据可视化： 1、Plotly - 提供了多种语言的库，支持在线创建交互式图表，包括2D和…
阅读更多...
mac｜Mysql WorkBench导入文件失败（修改编码）

mac｜Mysql WorkBench导入文件失败（修改编码）

⚠️：表格中有中文的不适用表格中有中文的不适用表格中有中文的不适用表格中有中文的不适用 我有一个excel表，想导入到mysql数据库中，但是Workbench的导入格式只支持csv，通过excel、wps将excel另存为csv文件进行导入 导入会因为编…
阅读更多...
【软件测试】之自动化测试

【软件测试】之自动化测试

🏀🏀🏀来都来了，不妨点个关注！ 🎧🎧🎧博客主页：欢迎各位大佬! 文章目录 什么是自动化测试Selenium介绍什么是SeleniumSelenium的特点工作原理 SeleniumJava环境搭建下载…
阅读更多...
第1章 信息系统综合知识

第1章 信息系统综合知识

第1章 信息系统综合知识 本章主要介绍信息系统综合知识，介绍信息、信息系统的基本概念，概述两化融合和国家信息化战略，讲解电子政务、电子商务的典型应用，描述信息化整体总体规划以及IT战略的主要内容。 1.1 信息的定义和属性 …
阅读更多...
【TB作品】矩阵键盘电话拨号，ATMEGA16单片机，Proteus仿真 atmega16矩阵键盘电话拨号

【TB作品】矩阵键盘电话拨号，ATMEGA16单片机，Proteus仿真 atmega16矩阵键盘电话拨号

atmega16矩阵键盘电话拨号 c代码和仿真图： 使用ATmega16实现矩阵键盘电话拨号功能 项目背景 在电子设计和嵌入式系统开发中，矩阵键盘是常见的人机交互方式。它可以实现较多按键的输入，同时节省单片机的I/O资源。结合LCD显示和蜂鸣器&am…
阅读更多...
Flume集群部署（手把手部署图文详细版）

Flume集群部署（手把手部署图文详细版）

前景概要： Kafka消息订阅系统在大数据业务中有着重要运用，尤其在实时业务中，kafka是必不可少的组件之一。 Flume是大数据组件中重要的数据采集工具，我们常利用Flume采集各种数据源的数据供其他组件分析使用。例如在实时业务中&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023