记录一次经历:使用flask_sqlalchemy集成flask造成循环导入问题

前言:

        工作需求,写一个接口,用Python来编写,我首先想到用flask小型框架来支撑,配置sqlalchemy来实现,但是在实现的过程中,发生循环导入问题

        我想到用蓝图来解决此问题,但是仍然会出死循环的问题,网上找了很多资料,许多都是轻描淡写,可能不是很明白,为了能够帮助更多踩坑的人,分享一下自己的经历!!

了解导入循环的机制

报错代码:

        cannot import name '......' from partially initialized module '.....'

Python的 死循环机制:

        当模块之间相互导入时,两个或多个模块之间相互依赖,它们通过import语句相互引用对方,而没有一个明确的导入顺序或者依赖管理来打破这种循环,形成了一个闭环,当尝试从任何一个模块中导入或执行函数时,Python 解释器将陷入无限循环的导入过程中

比如:A导入B,B导入A  

模块A:module_a.py

import module_b  def func_a():  print("Function A")  module_b.func_b()

模块B:module_b.py

import module_a  def func_b():  print("Function B")  module_a.func_a()

比如:A导入C,B导入A,C导入B

模块A:test1.py

import test3def t1():print('test1')test3.t3()t1()

模块B:test2.py

import test1def t2():test1.t1()print("test2")

模块C:test3.py

import test2def t3():test2.t2()print("test3")

解决sqlalchemy集成flask导入死循环的问题

        言归正传,要解决问题,要注意db实例化的位置,app导入的位置,蓝图导入的顺序!!!

解决方案:

   1. 在cab_api_test/views/__init__.py 文件下,实例化db,函数封装app   

   3. 导入蓝图时,如果蓝图有引用db,位置需要在db的下方  
   2. 在models中,main语句下,导入app,如果在全局还是会发生循环问题

        可能说的有些不清不楚,还是通过代码体现,就能明白啦,每步骤关键都有注释,注意好导入的顺序,和导入的位置,主要是app和db的位置,和模型创建用到的app导入问题!!

目录结构:

cab_api_test
├── app.py
├── gunicorn_config.py
├── logs
│   ├── cab_api_access.log
│   └── cab_api_error.log
├── requirements.txt
└── views
    ├── __init__.py
    ├── __pycache__
    │   ├── __init__.py
    │   ├── cab_api.py
    │   ├── filed_heck.py
    │   ├── logger.py
    │   ├── models.py
    │   └── session.py

cab_api_test/views/__init__.py

from flask import Flask
from flask_sqlalchemy import SQLAlchemydb = SQLAlchemy()# 1. 实例化db时 要注意导入蓝图的顺序!!!
# 2. 如果蓝图中有引用db,在这导入的蓝图必须在db的下面,不然还是会报错
# 3. 我是用的蓝图是 cab_api.py
from views.cab_api import cab_apihost = '127.0.0.1'
port = 3306
user = 'root'
password = 'wq123456'
database = 'gf_test'def create_app():app = Flask(__name__)app.config['DEBUG'] = True# sqlalchemy 连接池配置app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = Falseapp.config['SQLALCHEMY_DATABASE_URI'] = f'mysql+pymysql://{user}:{password}@{host}:{port}/{database}?charset=utf8mb4&autocommit=true'app.config['SQLALCHEMY_POOL_SIZE'] = 10app.config['SQLALCHEMY_POOL_TIMEOUT'] = 10app.config['SQLALCHEMY_MAX_OVERFLOW'] = 5app.config['SQLALCHEMY_POOL_PRE_PING'] = Trueapp.config['SQLALCHEMY_ECHO'] = False# 把app对象初始化到db中db.init_app(app=app)app.register_blueprint(cab_api, url_prefix='/api')return app

cab_api_test/views/models.py

import datetime
from uuid import uuid4
from sqlalchemy import Column, String, Text, DateTime# 这个db是全新的SQLAlchemy对象
from views import dbclass Cab_review(db.Model):__tablename__ = 'cab_review'  # 表名# 写字段uuid = Column(String(100), nullable=False, primary_key=True, default=str(uuid4()).replace('-', ''))cab_number = Column(String(64), nullable=True, comment='工单号')review_item = Column(String(100), comment='项目名')  # String(32) == varchar(32)review_info = Column(Text, comment='项目信息')review_link = Column(String(200), nullable=True, comment='项目链接')caller_id = Column(String(100), nullable=True, comment='调用方标识ID')caller_ip = Column(String(100), nullable=True, comment='调用方IP')updated_time = Column(DateTime, default=datetime.datetime.now, nullable=False, comment='更新时间')test_number = Column(String(64), nullable=True, comment='测试号')if __name__ == '__main__':  # 导入时不执行下面的语句,只有执行当前文件的时候才会执行下面的代码# 注意要在main下面导入create_app,如果在全局导入,还是会发生循环导入的问题from views import create_appapp = create_app()# 先清空再创建db.drop_all()db.create_all(app=app)# 做一个简单的封装 db,使用with 语句
class Session:def __init__(self):self.db = Nonedef __enter__(self):self.db = db.sessionreturn self.dbdef __exit__(self, exc_type, exc_val, exc_tb):if self.db:self.db.close()

 cab_api_test/views/cab_api.py

from flask import jsonify, request
import json, datetime
from uuid import uuid4
from views.logger import flask_logger
from views.filed_check import field_check
from flask import Blueprint
# Session 是我封装好的 db
from views.models import Cab_review, Sessioncab_api = Blueprint('cab_api', __name__)@cab_api.route('/', methods=['POST', ])
def main():# 传入的参数data = request.get_json()cno_test = data.get('cno_test')review_pro = data.get('review_pro')review_result = data.get('review_result')review_advice = data.get('review_advice')flask_logger.info(f'请求体:{data}')data['cno'] = '已废弃' if not data.get('cno') else data.get('cno')data['caller_ip'] = request.remote_addrdata['url'] = data.get('url') if data.get('url') else ''data['caller_id'] = data.get('caller_id') if data.get('caller_id') else '调用方未提供caller_id'# 校验字段ok, msg = field_check(cno_test, review_pro, review_result, review_advice)if not ok:flask_logger.info('-------------------------------------------------------------------------------------------------------')return jsonify(msg)# 查询cab_review中的数据with Session() as session:select_data = session.query(Cab_review).filter_by(test_number=cno_test,review_item=review_pro).all()  # [queryset,queryset],数据为空则 []session.begin()  # 开启事务if not select_data:try:cab_review = Cab_review(uuid=str(uuid4()).replace('-', ''),cab_number=data.get('cno'),review_item=data.get('review_pro').strip(),review_info=json.dumps({'review_result': data.get('review_result'),'review_advice': data.get('review_advice')},ensure_ascii=False),review_link=data.get('url'),caller_id=data.get('caller_id'),caller_ip=data.get('caller_ip'),test_number=data.get('cno_test'))session.add(cab_review)session.commit()flask_logger.info('数据插入成功')msg = '请求成功,数据已添加或更新'is_success = Trueexcept Exception as e:session.rollback()flask_logger.error(f'添加失败:{e}', exc_info=False)msg = '数据添加或更新失败,请联系管理员'is_success = Falseelse:try:session.query(Cab_review).filter_by(test_number=data.get('cno_test'),review_item=data.get('review_pro').strip()).update({'review_info': json.dumps({'review_result': data.get('review_result'), 'review_advice': data.get('review_advice')},ensure_ascii=False), 'review_link': data.get('url'),'caller_id': data.get('caller_id'),'caller_ip': data.get('caller_ip'), 'updated_time': datetime.datetime.now()})session.commit()flask_logger.info('数据更新成功')msg = '请求成功,数据已添加或更新'is_success = Trueexcept Exception as e:session.rollback()flask_logger.error(f'更新失败:{e}', exc_info=False)msg = '数据添加或更新失败,请联系管理员'is_success = Falsereview_name = ['评审项:' + review_pro, '评审结果:' + review_result, '评审意见:' + review_advice,'评审链接:' + data.get('url')]flask_logger.info('-------------------------------------------------------------------------------------------------------')return {'code': 200, 'success': is_success, 'msg': msg, 'data': '\n'.join(review_name)}@cab_api.route('/', methods=['GET', ])
def health_check():return 'ok'

这样就不会在发生导入死循环的问题啦!!! 

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

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

相关文章

基于PHP的文件上传

文件上传是现代网络应用中不可或缺的功能,它允许用户将本地文件存储到服务器上,用于后续的处理、分发或备份。 一、基于前端验证的文件上传 文件上传漏洞中的前端验证漏洞是一个常见且危险的问题。这类漏洞的产生主要是因为前端验证机制可以通过多种方…

设置虚拟机使用主机以太网而不是WiF连接

虚拟机使用主机的以太网连接而不是Wi-Fi连接,可以通过在虚拟化软件中配置虚拟机的网络设置来实现。以下是一些常见的虚拟化软件(如VMware和VirtualBox)中设置虚拟机网络以使用以太网连接的步骤: 一、VMware中设置 1、打开虚拟网…

微信小程序:点击事件(bindtap)传递参数

小程序在组件上绑定事件后&#xff0c;传递参数的方式不同于前端其他场景中直接加参数的方式&#xff0c;小程序在参数的传递时&#xff0c;采用事件对象的自定义属性的方式&#xff0c;具体实现如下&#xff1a; wxml&#xff1a; <view bindtap"goIndex" data…

JAVA双端队列Deque详解

Java中的双端队列&#xff08;Deque, 全称是double-ended queue&#xff09;是一种具有队列和栈的性质的抽象数据类型。双端队列中的元素可以从两端弹出&#xff08;在队列的头部和尾部进行添加或删除操作&#xff09;&#xff0c;因此它既可以作为FIFO&#xff08;先进先出&am…

天猫 登录滑块 淘系滑块分析

声明: 本文章中所有内容仅供学习交流使用&#xff0c;不用于其他任何目的&#xff0c;抓包内容、敏感网址、数据接口等均已做脱敏处理&#xff0c;严禁用于商业用途和非法用途&#xff0c;否则由此产生的一切后果均与作者无关 前言 玩了几天现在才有空研究轨迹直接用了之前的…

UEditor百度富文本后端上传文件接口

UEditor百度富文本后端上传文件接口 直接上代码 接口&#xff1a; RequestMapping("/UEditorConfig")public String list(HttpServletRequest request, HttpServletResponse response) throws IOException {String config environment.getProperty("ueditor.c…

SOMEIP_ETS_059: ResetInterface_wrong_Fire_and_forget_package_get_No_Error_back

测试目的&#xff1a; 验证设备&#xff08;DUT&#xff09;在接收到一个错误的Fire&Forget消息时&#xff0c;不会做出响应或发送错误消息。 描述 本测试用例旨在检查DUT在接收到使用无效接口版本的方法resetInterface的Fire&Forget消息时&#xff0c;是否不会回应…

React 入门第四天:理解React中的路由与导航

在React学习的第四天&#xff0c;我将目光聚焦在React Router上。路由是任何单页应用&#xff08;SPA&#xff09;的核心部分&#xff0c;决定了用户如何在应用中导航&#xff0c;以及不同URL对应的内容如何渲染。通过学习React Router&#xff0c;我体会到了React处理路由的强…

数据库里的幽灵数据 - SQLite WAL模式探秘

亲爱的开发者朋友们,你是否曾经遇到过这样一个令人困惑的场景:你辛辛苦苦地往数据库里插入了新数据,信心满满地打开数据库文件一看,结果却发现新数据仿佛人间蒸发了一般?不要慌,这篇文章将为你揭开这个神秘现象的面纱。 让我们从一个真实的故事开始。 小明是一个移动应用开发…

打卡学习Python爬虫第五天|Xpath解析的使用

什么是Xpath&#xff1f;是在XML文档中搜索内容的一门语言&#xff0c;HTML可以看作是xml的一个子集。 目录 1、安装lxml模块 2、导入lxml中的etree子模块 3、Xpath使用方法 3.1.选择节点 3.2.选择属性 3.3.选择文本内容 3.4.使用通配符*过滤节点 3.5.使用中括号[]索引…

C语言:文件(写入,读取)

磁盘文件分为文本文件和二进制文件。 区分二者很简单&#xff0c;我们可以选定一个文件&#xff0c;以记事本打开&#xff0c;如果其中的内容你能看懂&#xff0c;他就是一个文本文件&#xff0c;相反&#xff0c;如果是一堆你看不懂的东西&#xff0c;那他就是二进制文件。 …

Android T adout replace bootanimation

idea_1:use ota replace bootanimation.zip idea_2:创建一个新的分区,(用于存放bootanimation.zip)可以让上层读写. idea_3:su cp 前提条件&#xff1a;userdebug版本, 默认关闭selLinux,可root //df 查看设备分区情况,有些分区系统是不让去写的 adb shell c4_t:/ $ df Fil…

【STM32】一些外设通用内容

在学习各种外设的过程中&#xff0c;发现外设有一些通用的东西可以总结一下&#xff0c;后面发现再继续更新。图来源于正点原子的学习视频和PPT。 目录 1 外设的时钟的开启 2 外设初始化的回调机制 3 外设的中断服务函数 4 HAL库中断回调机制 5 函数的常见…

Onnx使用预训练的 ResNet18 模型对输入图像进行分类,并将分类结果显示在图像上

目录 一、整体功能概述 二、函数分析 2.1 resnet() 函数&#xff1a; 2.2 pre_process(img_path) 函数&#xff1a; 2.3 loadOnnx(img_path) 函数&#xff1a; 三、代码执行流程 一、整体功能概述 这段代码实现了一个图像分类系统&#xff0c;使用预训练的 ResNet18 模型对…

计算机毕业设计hadoop+spark+hive漫画推荐系统 动漫视频推荐系统 漫画分析可视化大屏 漫画爬虫 漫画推荐系统 漫画爬虫 知识图谱 大数据

流程&#xff1a;1.DrissionPageSelenium自动爬虫工具采集漫画视频、详情、标签等约200万条漫画数据存入mysql数据库&#xff1b; 2.Mapreduce对采集的动漫数据进行数据清洗、拆分数据项等&#xff0c;转为.csv文件上传hadoop的hdfs集群&#xff1b; 3.hive建库建表导入.csv动漫…

使用Python+os/shutil删除文件、空目录和非空目录

一、使用Python的os.remove函数删除文件 import os# 永久删除文件 if os.path.exists(test1.txt):os.remove(test1.txt) 二、使用Python的os.rmdir函数删除空文件夹 import os# 永久删除空目录 if os.path.exists(empty_directory):os.rmdir(empty_directory) 三、使用Pyth…

驱动开发系列11 - Linux Graphics 图形栈概述(二)

目录 一:GPU 和 硬件 现代 GPU 功能概览: 硬件结构: 屏幕驱动: 屏幕连接器: 屏幕 CRT 控制器: CPU与GPU通信: 现代主机通信总线介绍: 通信方法: GPU 编程:通过 MMIO 访问寄存器 CPU 和 GPU 内存请求路由: GPU 可访问的内存区域: GTT/GART 是 CPU 与 GPU 共享的通信缓…

R语言VAR模型的多行业关联与溢出效应可视化分析

全文链接&#xff1a;https://tecdat.cn/?p37397 摘要&#xff1a;本文对医疗卫生、通信、金融、房地产和零售等行业的数据展开深入研究。通过读取数据、计算收益率、构建 VAR 模型并进行估计&#xff0c;帮助客户进一步分析各行业变量的影响及残差的协方差与相关矩阵&#xf…

框架——MyBatis查询(单表查询,多表联查)

目录 1.单表查询 2.多表查询 想查询student并且查询student所选择的专业major ①通过id查一个 ②不传入值直接查所有的学生列表 ③嵌套查询 想查询专业major并且查询该专业被哪些学生student选择 ①通过id查一个 ②不传入值直接查所有的专业列表 ③嵌套查询 3. 设置自动…

SQL, 有终止条件的多次累计计算

MSSQL数据库的data表存储了多人上电梯的情况&#xff0c;turn表示进电梯的顺序。电梯最大承重1000公斤&#xff0c;每趟能上的人数有限&#xff0c;超重的人要等下一趟。nameweightturnAlice2501Bob1702Alex3503John4004Winston5005Marie2006 请计算每趟电梯最后一个进入的人的…