Flask-Celery 2.4.3

使用Flask与Celery

从Celery 3.0开始，不再推荐使用Flask-Celery集成包，您应该使用标准的Celery API。

请阅读Celery入门教程

http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html

您可以将Celery轻松添加到Flask应用程序中，如下所示

myapp.py:

from celery import Celery

celery = Celery('myapp', broker='amqp://guest@localhost//')

@celery.task
def add(x, y):
    return x + y

要启动工作进程，您可以启动指向您的celery应用程序实例的celery worker命令

$ celery -A myapp worker -l info

(如果app参数是模块/包而不是属性，它将自动展开为myapp.celery)

查看命令帮助屏幕以获取更多信息

$ celery help

如果您想将 Flask 配置作为 celery 配置的来源，您可以这样做：

celery = Celery('myapp')
celery.config_from_object(flask_app.config)

如果您需要在任务内部访问请求，则可以使用测试上下文。

from flask import Flask
from celery import Celery

app = Flask('myapp')
celery = Celery('myapp')

celery.config_from_object(app.config)

@celery.task
def hello():
    with app.test_request_context() as request:
        print('Hello {0!r}.format(request))