Flask-Celery 2.4.3

使用带芹菜的烧瓶

从芹菜3.0烧瓶芹菜集成包不再 建议使用标准芹菜api。

请阅读芹菜入门教程：

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

您可以轻松地将芹菜添加到烧瓶应用程序中，如下所示：

myapp.py：

from celery import Celery

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

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

要启动辅助进程，可以启动celery worker命令 通过指向celeryapp实例：

$ celery -A myapp worker -l info

（如果app参数（-A|--app)是模块/包而不是 属性 它将自动扩展到myapp.celery）

有关详细信息，请参见“命令帮助”屏幕：

$ celery help

如果你想用烧瓶配置作为芹菜的来源 配置您可以这样做：

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))