首先,介绍下我的项目:Flask+Flask-SQLAlchemy,相关配置如下:
# config.py MYSQL_URL = 'mysql+mysqlconnector://xxx/db_name' DEBUG = True SQLALCHEMY_ECHO = True SQLALCHEMY_DATABASE_URI = MYSQL_URL SQLALCHEMY_TRACK_MODIFICATIOnS= False SQLALCHEMY_POOL_RECYCLE = 3000 SQLALCHEMY_ENCODING = "utf8mb4" # application.py from flask_sqlalchemy import SQLAlchemy db = SQLAlchemy() ...... self.config.from_pyfile('config.py') db.init_app(self) 我现在的功能是:前面的功能一切正常,数据库增删改查也正常,随后进入一个扫描过程,是一个第三方的扫描工具,扫描完成后生成一串数据量很大的扫描结果( json 串),然后我循环这个 json 串,拿出里面的 ip ( ip 数量很多),然后在循环里根据 ip 查询其 id,就这个过程报异常:
(mysql.connector.errors.OperationalError) MySQL Connection not available 大概代码如下:
for result in nminfo['scan'].values(): if result['status']['state'] == "up": ip = result['addresses']['ipv4'] host_os = "xxx" # 位置 1 host_assets_id = db.session.query(HostAsset.host_id).filter(HostAsset.host_ip == ip).first() if host_assets_id: query_host_id = host_assets_id[0] # 位置 2 HostAsset.query.filter_by(host_id=query_host_id).update({'host_os': host_os}) HostAssetsHistory.query.filter_by(host_id=query_host_id, task_stream_id=self.task_stream_id).update({'host_os': host_os}) db.session.commit() else: pass 这个扫描过程,当这个扫描数据比较少的时候,扫描完成的时间就比较短。经过测试,扫描时间短的时候,不会报异常,程序正常跑完。但是当这个扫描的数据量大的时候,待扫描完成,查询数据库就报如上异常。
很奇怪,感觉是不是:扫描时间长,扫描过程与数据库没有交互,自动与数据库断开连接了?
我的 mysql 相关配置如下图:

