芹菜配置

Question

我已經配置芹菜運行異步就業崗位上開發框的燒瓶中的應用程序是這樣的：

config.py：

class CeleryConfig(object): 
    CELERY_BROKER_URL = 'redis://localhost:6379/0' 
    CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' 
CELERY_CONFIG = CeleryConfig 

manage.py：

celery_app = celery.Celery(config_source=app.config.get('CELERY_CONFIG')) 

def run_celery(): 
    appl = celery.current_app._get_current_object() 
    celery_worker = celery_worker.worker(app=appl) 
    options = { 
     'broker': config.get('CELERY_CONFIG').CELERY_BROKER_URL, 
     'traceback': True, 
    } 
    celery_worker.run(**options) 

啓動應用程序

之前，我開始的Redis：

./redis-server --daemonize yes 

然後當我運行應用程序（run_celery）我得到顯示以下芹菜配置：

• ** ---------->運輸：AMQP：//嘉賓：** @本地主機：5672 //
• ** ---------->結果：redis的：//本地主機：6379/0

和以下的重複誤差：

ERROR/MainProcess使用者：無法連接到amqp：// guest：**@127.0.0.1：5672 //：[Errno 111]連接被拒絕。

我不知道爲什麼傳輸層使用RabbitMQ，爲什麼我不能得到芹菜開始。

Answer 1

這是因爲參數是BROKER_URL而不是CELERY_BROKER_URL。以下是可能設置的完整列表：http://docs.celeryproject.org/en/latest/userguide/configuration.html#new-lowercase-settings

注意：該表是Celery 4.0中新的小寫設置的轉換表，但如前所述：「Celery仍然能夠讀取舊的配置文件，因此不急於轉向新的設置格式「