在Flask中,我启动另一个线程来运行一个耗时的任务,需要更新mysql,我怎么能在这个线程中使用Flask_sqlalchemy?
我在网站上请求网址时尝试运行bash脚本。因为bash脚本需要很长时间才能运行,所以我不希望它阻止了烧瓶的主线程。所以我开始另一个线程来运行它。当我这样做时,我发现我需要让烧瓶的app_context
使用Flask_sqlalchemy
。所以我喜欢这样:
我的部分代码:
@manage_git.route('/makefile', methods=['POST'])
def makefile():
Threading(target=mkfile, args=(local_git_dir, git_id)).start()
return redirect(url_for('manage_git.index'))
def mkfile(local_git_dir, git_id):
from manage import app
subprocess.Popen(['bash', 'makefile.sh'])
with app.app_context():
git_db = GitDb.query.filter_by(id=git_id).first()
git_db.make = True
db.session.add(git_db)
db.session.commit()
我只是想让app_context使用Flask_sqlalchemy,但我导入了一个全局变量app
。我不认为这是解决这个问题的好方法。
这对我有很大的帮助,如果你能告诉我:有没有更好的方法来获得flask的app_context?还是有另一种更好的方法来解决我的问题?
- - 补充 - -
ext是.朋友 :
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()
init.朋友 :
from flask import FLask
from config import config
from .exts import db, login_manager
def create_app(config_name):
app = Flask(__name__)
app_config = config[config_name]
app.config.from_object(app_config)
app_config.init_app(app)
db.init_app(app)
from .manage_git import manage_git as manage_git_blueprint
app.register_blueprint(manage_git_blueprint)
# ......
return app
manage.朋友 :
from app import create_app
from app.models import *
app = create_app('default')
if __name__ == '__main__':
app.run()
你是如何创建应用程序和数据库对象的?根据Flask-SQLAlchemy文档,如果您只在App对象上使用,则可以将app对象传递给SQLAlchemy()调用:
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:////tmp/test.db'
db = SQLAlchemy(app)
现在,当您导入数据库时,您无需导入应用程序或使用app_context:
def mkfile(local_git_dir, git_id):
subprocess.Popen(['bash', 'makefile.sh'])
git_db = GitDb.query.filter_by(id=git_id).first()
git_db.make = True
db.session.add(git_db)
db.session.commit()
http://flask-sqlalchemy.pocoo.org/2.3/contexts/和http://flask-sqlalchemy.pocoo.org/2.3/quickstart/有关于此过程和替代方案的更多信息。