flask+python快速搭建

app.py

"""APP 入口模块"""
from traceback import format_excfrom api_limiter import limiter
from flask import Flask, jsonify
import loggingfrom controller import api_sql_blueapp = Flask(__name__)
limiter.init_app(app)
app.register_blueprint(api_sql_blue)@app.errorhandler(Exception)
def handle_exception(e):"""处理所有异常"""logging.error(format_exc())# 返回 JSON 错误响应return jsonify(error=str(e)), 500if __name__ == '__main__':app.run(debug=True,threaded=True)

controller.py

from flask import Blueprint, make_responsefrom response_dic import ResDic
from api_limiter import limiter
from flask import jsonify, request
from functools import wraps
from jsonschema import validate, ValidationErrorfrom sql_service import sql_import_deal, sql_query_dealapi_sql_blue = Blueprint('sql', __name__)def validate_json_and_schema(schema):"""验证请求数据是否是JSON格式,以及是否符合schema"""def decorator(f):@wraps(f)def wrapper(*args, **kwargs):if request.is_json:data = request.get_json()try:validate(instance=data, schema=schema)except ValidationError as e_validation:return jsonify(ResDic.from_params(code="400", msg=str(e_validation))), 200return f(*args, **kwargs)else:return jsonify(ResDic.from_params(code="400", msg="请求数据不是JSON格式")), 200return wrapperreturn decoratordef header_required(func):@wraps(func)def decorated_function(*args, **kwargs):authorization_header = request.headers.get('Authorization')if not authorization_header:return jsonify(ResDic.from_params(code="401", msg="请求参数异常")), 200return func(*args, **kwargs)return decorated_function@api_sql_blue.route('/import', methods=['POST'])
@validate_json_and_schema({"type": "object","properties": {"sql_txt": {"type": "string"}},"required": ["sql_txt"],
})
@limiter.limit("5/second", override_defaults=False)  # 一秒5次
@header_required
def sql_import():req_json_data = request.get_json()req = req_json_data["sql_txt"]result = sql_import_deal(req)response_data = jsonify(ResDic.from_params(code="0", data=result))response = make_response(response_data)return response@api_sql_blue.route('/query', methods=['POST'])
@limiter.limit("5/second", override_defaults=False)  # 一秒5次
@header_required
@validate_json_and_schema({"type": "object","properties": {"question": {"type": "string"}},"required": ["question"],
})
def sql_query():req_json_data = request.get_json()req = req_json_data["question"]result = sql_query_deal(req)response_data = jsonify(ResDic.from_params(code="0", data=result))response = make_response(response_data)return response

api_limiter.py

from flask_limiter import Limiter
from flask_limiter.util import get_remote_addresslimiter = Limiter(key_func=get_remote_address,default_limits=["50000 per day", "3600 per hour"]
)

response_dic.py

class ResDic:def __init__(self, code, data, msg):self.code = codeself.data = dataself.msg = msg@classmethoddef from_params(cls, code="200", data="", msg=""):return {"code": code, "data": data,"msg": msg}

sql_service.py

def sql_import_deal(req:str):return "import"def sql_query_deal(req:str):return "query"

config_utils.py

from dotenv import load_dotenv
import osload_dotenv('.env')  # 先加载默认的 .env 文件APP_ENV = os.environ.get('APP_ENV', 'dev').lower()
load_dotenv(f'.env_{APP_ENV}', override=True)  # 再加载环境相关的,def get_config(key: str) -> str:return os.environ.get(key)

.env

OPENAI_API_KEY=""

requirements.txt

Flask==2.3.2
Flask-Limiter==3.3.1
gevent==22.10.2
gunicorn==20.1.0
jsonschema==4.18.0
jsonschema-specifications==2023.6.1
numpy==1.23.5
numexpr==2.8.4
openai==0.27.4
openapi-schema-pydantic==1.2.4
py-healthcheck==1.10.1
pydantic==1.10.7
pydub==0.25.1
faiss-cpu==1.7.4
typing-inspect==0.8.0
typing_extensions==4.5.0
tiktoken==0.4.0
beautifulsoup4==4.12.2
gradio==3.36.1
pytest==7.4.0
python-dotenv==1.0.0
pymysql==1.1.0
urllib3==1.25.11

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

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

相关文章

golang:context

context作用 goroutine的退出机制 多个goroutine都是平行的被调度的,多个goroutine如何协调工作涉及通信、同步、通知和退出 通信:goroutine之间的通信同步chan通道 同步:不带缓冲的chan提供了一个天然的同步等待机制。通过WaitGroup也可以…

【学习草稿】背包问题

一、01背包问题 图解详细解析 (转载) https://blog.csdn.net/qq_37767455/article/details/99086678 :Vi表示第 i 个物品的价值,Wi表示第 i 个物品的体积,定义V(i,j):当前背包容量 j,前 i 个物…

Kubernetes组件和架构简介

目录 一.概念简介 1.含义: 2.主要功能: 3.相关概念: 二.组件和架构介绍 1.master:集群的控制平面,管理集群 2.node:集群的数据平面,为容器提供工作环境 3.kubernetes简单架构图解 一.概…

技战法-信息收集

搜索引擎语法 Google hacking: site: 限制搜索范围为某一网站,例如: site:baidu.com"admin”可以搜索baidu.com 网站上包含关键词“admin”的页面。 inurl: 限制关键字出现在网址的某个部分,例如: inurl:php?id 可以搜索网址中包含 ph…

Kafka 运维必懂:从原理到调优,看完秒变大佬

1 Kafka 概述 Kafka 起初是 由 LinkedIn 公司采用 Scala 语言开发的一个多分区、多副本且基于 ZooKeeper 协调的分布式消息系统,现已被捐献给 Apache 基金会。 目前 Kafka 已经定位为一个分布式流式处理平台,它以高吞吐、可持久化、可水平扩展、支持流…

Spring源码分析 循环依赖 三级缓存

文章目录 本文目的类图什么是循环依赖如何解决Spring三级缓存三个缓存分别放的是什么? 如果只有二级缓存代理和三级缓存二级缓存在其中的作用 源码分析创建对象之前先从缓存中查找从一二三级缓存中依次查找对象对象实例化时放入到三级缓存中何时放入一级缓存 本文目…

腾讯云cvm云硬盘扩容

过去一直记得腾讯云的系统盘扩容,关于系统盘的扩容直接点资源调整-云硬盘扩容 系统盘扩容后就可以直接使用的? 但是现在操作了发现vda 200G 但是现在vda1不能自动扩容了? 腾讯云cvm云硬盘扩容 先看一眼官方文档吧:在线扩展系统盘分区及文…

LeetCode每日一题:1993. 树上的操作(2023.9.23 C++)

目录 1993. 树上的操作 题目描述: 实现代码与解析: 模拟 dfs 原理思路: 1993. 树上的操作 题目描述: 给你一棵 n 个节点的树,编号从 0 到 n - 1 ,以父节点数组 parent 的形式给出,其中 p…

Android开发MVP架构记录

Android开发MVP架构记录 安卓的MVP(Model-View-Presenter)架构是一种常见的软件设计模式,用于帮助开发者组织和分离应用程序的不同组成部分。MVP架构的目标是将应用程序的业务逻辑(Presenter)、用户界面(V…

Mybatis自动映射Java对象 与 MySQL8后的JSON数据

文章目录 Mybatis自动映射Java对象 与 MySQL8后的JSON数据1.转化成为正常Json类型1.1 JsonTypeHander1.2 ListJsonTypeHandler 负责List<T> 类型1.3 实体类1.4 mapper1.5 测试类 2. 存储为携带类型的Json Mybatis自动映射Java对象 与 MySQL8后的JSON数据 1.转化成为正常…

【密码学补充知识】

&#x1f511;密码学&#x1f512;概述 &#x1f4d5; 1.基本概念 明文 &#xff1a; 要交换的信息 密文 &#xff1a; 明文经过一组规则变换成看似没有意义的随机消息。 加密 &#xff1a; 明文经过一组规则变换成密文的过程 解密 &#xff1a; 密文恢复出明文的过程 加…

MT1184矩形相交 题解【超详细】

目录 题目 样例 题目解析 代码 图解 矩形相交 题目 输入2个矩形的左上角和右下角两个点的坐标值(x&#xff0c;y)&#xff0c;判断2个矩形是否相交&#xff0c;输出YES或者NO。矩形的边应与x&#xff0c;y轴相平行。假定输入坐标能顺利构成矩形&#xff0c;不考虑无效矩形…

macOS使用官方安装包安装python

新手程序员可能想知道如何在 Mac 上正确安装 Python&#xff0c;这里介绍在 macOS 上安装 Python 的方法。 操作步骤 1.从 Python 官方网站 (python.org) 下载最新的 Python 版本. 单击 macOS 链接并选择最新的 Python 版本。 2.下载完成后&#xff0c;双击包开始安装Python…

二、ubuntu主机端tftp及nfs服务开发环境安装

一.主机端tftp服务环境安装及配置 检查是否已经安装tftp server $dpkg -s tftpd-hpa#如果提示未安装服务&#xff0c;则执行下面安装指令$sudo apt-get install tftpd-hpa tftp-hpa#tftpd-hpa服务端 tftp-hpa客户端创建tftp启动目录&#xff0c;用于存放内核与设备树文件&a…

利用 spring test 实现自动启动spring 容器进行 JPA接口测试

自动启动context JPA接口测试 import com.alibaba.druid.pool.DruidDataSource; import org.junit.BeforeClass; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cont…

第6讲:v-for使用

目录 1.循环遍历 2.v-for遍历整形变量&#xff08;99乘法表&#xff09; 3.v-for遍历普通数组 4.v-for遍历数组对象 1.循环遍历 v-for指令基于一个数组渲染一个列表&#xff0c;它和JavaScript的遍历语法相似&#xff1a; v-for”item in list” list 是一个数组&#xff0c; i…

[C++ 网络协议] Windows中的线程同步

目录 1. 用户模式(User mode)和内核模式(Kernal mode) 2. 用户模式的同步(CRITICAL_SECTION) 3. 内核模式同步 3.1 互斥量 3.2 信号量 3.3 事件对象 4. 实现Windows平台的多线程服务器端 1. 用户模式(User mode)和内核模式(Kernal mode) Windows操作系统的运行方式是“…

windows平台 git bash使用

打开所在需要git管理的目录,鼠标右键open Git BASH here 这样就直接进来,不需要windows dos窗口下麻烦的切路径&#xff0c;windows和linux 路径方向不一致 (\ /) 然后git init 建立本地仓库,接下来就是git相关的操作了. 图形化界面查看 打开所在需要git管理的目录,鼠标右键…

kubernetes问题(一)-探究Pod被驱逐的原因及解决方法

1 k8s evicted是什么 k8s evicted是Kubernetes中的一个组件&#xff0c;主要用于处理Pod驱逐的情况。在Kubernetes中&#xff0c;当Node节点资源不够用时&#xff0c;为了保证整个集群的运行稳定&#xff0c;会按照一定的优先级和策略将其中的Pod驱逐出去。这时就需要一个组件…

软考高级架构师下篇-17安全架构设计理论与实践

目录 1. 引言信息安全面临的威胁2. 安全体系架构的范围3.典型安全模型4.信息安全整体架构设计5.数据库系统安全设计6.系统架构脆弱性分析7.安全架构设计实践8. 前文回顾1. 引言 随着科技的发展,信息系统的安全受到诸多方面的威胁,设计信息系统安全架构需要从各个方面考虑,这…