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)