flask插件系列之flask_celery异步任务神器 

在Flask中集成celery需要做到两点：

1. 创建celery的实例对象的名字必须是flask应用程序app的名字,否则celery启动会失败；

2. celery必须能顺利加载初始化文件。

celery在flask中初始化

启动celery之前需要加载flask的app的配置，因此需要创建一个app对象给celery使用。

# run_celery.py
import create_app
flask_app = create_app("develop") # 创建app的同时，对celery完成了加载配置的工作
from extensions import celery # 此时的celery对象已经在上下文中完成初始化

# 找到celery实例的位置，指定worker，指定接收某个队列的消息，如果不指定则接收所有队列的消息
celery -A run_celery.celery worker -Q eegqueue --loglevel=info

• 参考：

• https://pypi.org/project/Flask-Celery-Helper/#description