芹菜3瓶整合

我試圖讓這個啓動和運行一個基本的例子：芹菜3瓶整合

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

但到目前爲止，它只是沒有任何意義去哪裏。

有人請提供一個簡單的Flask-Celery 3工作示例。

問候，

卡爾

來源

2014-03-03 user1513388

當您嘗試此設置時，您會得到什麼錯誤？ –

好吧，我發現這個https://github.com/thrisp/flask-celery-example。事情現在更有意義。 – user1513388

-2

Github Repo for Flask-Celery

我引用筆者

芹菜3.0這個庫不再是必要的，相反，你應該使用標準的芹菜API

因爲這個原因沒有必要使用燒瓶芹菜，芹菜是獨立的燒瓶。請使用Flask良好的圖案。

來源

2014-05-11 04:13:33 yograterol

原來的問題沒有提到燒瓶芹菜庫。他沒有使用它。他正在使用標準的芹菜API。 –

回答

相關問題