我正在尝试找到一个基本的例子来说明这个问题:
http://flask.pocoo.org/docs/patterns/celery/
因此,本文建议将其放在一个任务模块中:
from celery import Celery
def make_celery(app):
celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)
TaskBase = celery.Task
class ContextTask(TaskBase):
abstract = True
def __call__(self, *args, **kwargs):
with app.app_context():
return TaskBase.__call__(self, *args, **kwargs)
celery.Task = ContextTask
return celery还有这个烧瓶应用程序。
from flask import Flask
flask_app = Flask(__name__)
flask_app.config.update(
CELERY_BROKER_URL='redis://localhost:6379',
CELERY_RESULT_BACKEND='redis://localhost:6379'
)
celery = make_celery(flask_app)
@celery.task()
def add_together(a, b):
return a + b 但到目前为止,它只是没有任何意义的去向。
谁能提供一个简单的酒瓶-芹菜3工作的例子。
致以敬意,
卡尔
发布于 2014-05-11 04:13:33
https://stackoverflow.com/questions/22157550
复制相似问题