5,651

flask实战—异步处理

最近遇到一个问题就是执行某个操作,也要对数据库进行读写,且数量较大,时间比较久,用户点击一个按钮,会卡很久才跳出完成或刷新页面,这显然不符合用户体验,可以说是体验很差,后来去了解了一些线程、好像一旦访问数据库就会报app不存在或未定义等错误。后来找到一个方法,但是一开始也不太懂的新建app,然后用原生态的sql命令对数据库进行增删改查,这虽然解决了页面卡顿问题,但是后台的增删改查操作却显得比较繁琐,很明显这也不太符合做开发。后来上网查阅资料,发现可以自己在该异步函数中新建一个app,即可访问数据库,但好像有个不好的地方,是只能用db.session的方法来查询数据库,也不太清楚会不会出现什么问题,相对于原生的sql语句,这也大大提高了数据库的访问效率。

代码如下:

from concurrent.futures import ThreadPoolExecutor
@app.route('/upload_file', methods=['POST'])
def main():
    executor = ThreadPoolExecutor(1) ### 参数表示最大的线程数
    executor.submit(test, args)#其中test为异步函数,args为异步函数的参数
    return 'ok'

当执行上面的函数时,会很快返回ok,test函数会在后台继续执行。而上面说的解决app未定义的情况,代码如下:

def test(args):
    '''
    异步执行函数
    '''
    from config import config
    from flask import Flask
    from flask_sqlalchemy import SQLAlchemy
    app = Flask("report")
    app.config.from_object(config['test'])
    db = SQLAlchemy(app)
    ...#这里即可对数据库进行增删改查操作

原理是重新新建一个app,并连接我们的数据,配置文件为test,配置文件如下:

class TestConfig(Config):
    """
    设置多数据库访问,默认访问SQLALCHEMY_DATABASE_URI的数据库
    在建数据表模型的时候指定__bind_key__ = 'test'时,则表会被建到report的数据库中
    """
    DEBUG = True
    # SQLALCHEMY_ECHO = True
    # SQLALCHEMY_COMMIT_ON_TEARDOWN = True
    CELERY_BROKER_URL = 'redis://localhost:6379/0'
    CELERY_BACKEND_URL = 'redis://localhost:6379/0'
    SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:[email protected]:3306/database"
    SQLALCHEMY_BINDS = {
    'test':'mysql+pymysql://root:[email protected]:3306/database',
    }
config = {'test':TestConfig}

发表评论

邮箱地址不会被公开。 必填项已用*标注