记录一次经历:使用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.rhkb.cn/news/407740.html

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

相关文章

认知杂谈22

今天分享 有人说的一段争议性的话 I I 私人空间,成长的温床 咱一说到成长啊,可不能小瞧了外部环境对咱的影响。这环境啊,那可不是无关紧要的事儿,实际上呢,它对咱的成长起着特别关键的作用。你就想想看&#xff0c…

NRC-SIM:基于Node-RED的多级多核缓存模拟器

整理自: 《NRC-SIM: A NODE-RED Based Multi-Level, Many-Core Cache Simulator》,由 Ezequiel Trevio 撰写,作为他在德克萨斯大学里奥格兰德河谷分校攻读电气工程硕士学位的部分成果。以下是论文的详细主要内容: 摘要(Abstract…

uni-app01

工具:HuilderX noed版本:node-v17.3.1 npm版本:8.3.0 淘宝镜像:https://registry.npmmirror.com/ 未安装nodejs可以进入这里https://blog.csdn.net/a1241436267/article/details/141326585?spm1001.2014.3001.5501 目录 1.项目搭建​编辑 2.项目结构 3.使用浏览器运行…

鸿蒙OS promptAction的使用

效果如下: import { promptAction } from kit.ArkUIlet customDialogId: number 0Builder function customDialogBuilder() {Column() {Blank().height(30)Text(确定要删除吗?).fontSize(15)Blank().height(40)Row() {Button("取消").onClick…

无心剑中译莎士比亚《吾爱稀罕胜天仙》

莎士比亚十四行诗第130首 Sonnet 130 吾爱稀罕胜天仙 My mistress’ eyes are nothing like the sun; Coral is far more red than her lips’ red; If snow be white, why then her breasts are dun; If hairs be wires, black wires grow on her head. I have seen roses d…

WebRTC支持H.265编码:技术挑战与EasyCVR视频汇聚平台解决方案

随着互联网技术的快速发展,视频通信已成为人们日常生活和工作中不可或缺的一部分。WebRTC(Web Real-Time Communication)作为一种实时通信技术,因其便捷性和高效性而受到广泛关注。然而,在视频编码格式上,W…

Vue实现表格数据的增删改查

整体效果图&#xff1a; 一、创建表格数据 效果图&#xff1a; el-table组件&#xff1a;表格组件 <el-table:data"dataList"borderv-loading"dataListLoading"selection-change"selectionChangeHandle"style"width: 100%;">&l…

android aar适配uniapp

最近有商户需要接入我们sdk&#xff0c;但是我们都是android或者ios原生的&#xff0c;直接用又不能用&#xff0c;需要做适配&#xff0c;本文就教你一步步实现android aar适配uniapp。 官方参考教程&#xff1a;开发者须知 | uni小程序SDK 但是官方写的比较繁琐&#xff0c;好…

PostgreSQL 与对象存储的结合: 在 MinIO 中访问外部数据

数据领域最激动人心的发展之一是湖仓一体功能在所有主要数据库供应商中的兴起。Snowflake 和 SQL Server 长期以来一直采用这一点&#xff0c;现在 PostgreSQL 正在通过 pg_lakehouse 拥抱这种范式转变&#xff0c;使得利用现代数据湖进行分析、AI 等比以往任何时候都更容易。随…

解决Java使用Jsoup后台调用天地图地理编码接口的几个问题

目录 前言 一、天地图的地理编码接口 1、相关的API介绍 2、响应接口 二、使用JSOUP调用相应接口面对的问题及应对 1、第一关访问路径的问题 2、第二关UnsupportedMimeTypeException 3、可能的http获取403问题 三、总结 前言 如果你现在的项目中有如下的需求&#xff0c;…

[JavaEE] 工作流- Activiti7 框架详解

目录 1、Activiti介绍 1.1、BPMN设计器 1.2、常见流程符号 1.2.1、事件event 1.2.2、活动activiti 1.2.3、流向flow 2、入门案例 2.1、需求说明 2.2、初始环境 2.2.1、添加依赖 2.2.2、添加配置 2.2.3、添加引导类 2.2.4、启动项目 2.2.5、表结构 2.2.6、常见ap…

解决 mfc140.dll 文件丢失的问题,5种mfc140.dll解决方法

当您尝试启动一个用 Microsoft Visual Studio 2015 开发的 Windows 应用程序时&#xff0c;如果出现“无法找到 mfc140.dll 文件”的错误&#xff0c;请不要紧张。这类问题通常由DLL文件缺失、损坏或未正确安装引起。好消息是&#xff0c;存在多种解决方案可以帮助您解决这一挑…

Vue指令:v-cloak、v-once、v-pre 指令

Vue 指令系列文章&#xff1a; 《Vue插值&#xff1a;双大括号标签、v-text、v-html、v-bind 指令》 《Vue指令&#xff1a;v-cloak、v-once、v-pre 指令》 《Vue条件判断&#xff1a;v-if、v-else、v-else-if、v-show 指令》 《Vue循环遍历&#xff1a;v-for 指令》 《Vue事件…

【机器学习练习】糖尿病预测

&#x1f368; 本文为&#x1f517;365天深度学习训练营 中的学习记录博客&#x1f356; 原作者&#xff1a;K同学啊 一、数据预处理 1. 数据导入 import numpy as np import pandas as pd import seaborn as sns from sklearn.model_selec…

css 将背景图片居中显示,并且显示全,不拉伸的效果实现,图片设置宽度,高度自适应,并且显示全。

1、背景自适应的css&#xff1a; .bg-tns {background-image: url(img/xxx.jpg);background-size: cover;background-position: center; /* 将图片居中显示 */min-height: calc(100vh-100px); /* 确保至少为视口高度 */} 这个布局是这样的&#xff1a; 这里的背景图的高度&am…

unity Standard Assests资源商店无法安装解决方案

Unity游戏开发 “好读书&#xff0c;不求甚解&#xff1b;每有会意&#xff0c;便欣然忘食。” 本文目录&#xff1a; Unity游戏开发 Unity游戏开发unity中国 嗨嗨嗨&#xff0c;我来啦。 这几天的川渝之旅已经圆满结束了&#xff0c;今天开始正常给大家更新&#xff1a; Unity…

Unity与UE,哪种游戏引擎适合你?

PlayStation vs Xbox&#xff0c;Mario vs Sonic&#xff0c;Unreal vs Unity&#xff1f;无论是游戏主机、角色还是游戏引擎&#xff0c;人们总是热衷于捍卫他们在游戏行业中的偏爱。 专注于游戏引擎&#xff0c;Unity和Unreal Engine&#xff08;简称UE4&#xff09;是目前市…

利用漏洞实现 Outlook 的 RCE:第 2 部分

## 攻击面 Outlook 要播放的声音文件是波形音频文件格式( WAV)。它通过接收声音文件路径的PlaySound函数播放。PlaySound将加载文件、解析它,然后调用soundOpen,后者将调用不同的波形函数,例如waveOutOpen。 WAV 文件充当多个音频编解码器的容器(或包装器)。编解码器是一…

Shire 0.5 发布:构建数据安全 RAG,充分整合研发资产

最近&#xff0c;我们发布了新版本的 Shire&#xff0c;在这个新的发布&#xff08;Shire 0.5&#xff09;里&#xff0c;你可以更好地融合本地研发资产&#xff0c;同时构建数据安全 RAG。在这次版本中&#xff0c;我们增加了&#xff1a; 对 SonarQube 的 issue 支持。可以直…

从0到1构建视频汇聚生态:EasyCVR视频汇聚平台流媒体协议支持的前瞻性布局

TSINGSEE青犀EasyCVR视频汇聚平台是一款基于云-边-端一体化架构的视频融合AI智能分析平台&#xff0c;广泛应用于工地、仓储、工厂、社区、校园、楼宇等多个领域。平台凭借其强大的数据接入、处理、转码及分发能力&#xff0c;在视频监控领域展现出显著的技术优势和应用前景。本…