flask 多线程上下文管理

柯浩壤
2023-12-01

1、在flask主线程中利用多线程拉取数据并存储到数据库。

在线程中会遇到没有flask的上下文,导致找不到数据库问题。

解决方案:

1)在创建线程时候,传入app参数

app = create_app(config_mode)
Migrate(app, db)

# 我的逻辑
thread_dau = threading.Thread(target=get_dau_by_inteval, args=(app,))
thread_dau.start()
thread_dau.join()

2)在线程函数中,通过with引入flask上下文,就可以正常使用sqlalchemy来存取MySQL数据库了。

 

def get_dau_by_inteval(app):
    # from gentelella import app
    with app.app_context():
        while True:
            print("get_dau_by_inteval")
            get_dau_thread_func()
            time.sleep(60)

 

 类似资料: