2011-09-02 230 views
2

我想設置與芹菜Django,所以我可以在後臺發送批量電子郵件。芹菜在Django(RabbitMQ與Django數據庫)

我對如何將不同的組件發揮到芹菜有點困惑。我需要使用RabbitMQ嗎?我可以只用「django-kombu」來運行芹菜嗎? (http://ask.github.com/celery/tutorials/otherqueues.html#django-database

我開始在Django的芹菜文檔「第一步和Django」(http://django-celery.readthedocs.org/en/latest/getting-started/first-steps-with-django.html),但是當我到達「運行芹菜工作服務器」出現這種情況:

$ python manage.py celeryd -l info 
[2011-09-02 18:35:00,150: WARNING/MainProcess] 

-------------- [email protected] v2.3.1 
---- **** ----- 
--- * *** * -- [Configuration] 
-- * - **** --- . broker:  amqplib://[email protected]:5672/ 
- ** ---------- . loader:  djcelery.loaders.DjangoLoader 
- ** ---------- . logfile:  [stderr]@INFO 
- ** ---------- . concurrency: 2 
- ** ---------- . events:  OFF 
- *** --- * --- . beat:  OFF 
-- ******* ---- 
--- ***** ----- [Queues] 
-------------- . celery:  exchange:celery (direct) binding:celery 


[Tasks] 
    . tasks.add 

[2011-09-02 18:35:00,213: INFO/PoolWorker-2] child process calling self.run() 
[2011-09-02 18:35:00,214: INFO/PoolWorker-1] child process calling self.run() 
[2011-09-02 18:35:00,229: WARNING/MainProcess] [email protected] has started. 
[2011-09-02 18:35:00,276: ERROR/MainProcess] Consumer: Connection Error: [Errno 61} Connection refused. Trying again in 2 seconds... 
[2011-09-02 18:35:02,283: ERROR/MainProcess] Consumer: Connection Error: [Errno 61] Connection refused. Trying again in 4 seconds... 

然後我要退出進程...

回答

4

,我可以從你的配置看,你沒有正確設置的運輸,其實芹菜是試圖用amqplib像兔子MQ到代理的連接

broker:  amqplib://[email protected]:5672/ 

應設置在settings.py,券商後端以這樣的方式

BROKER_BACKEND = "djkombu.transport.DatabaseTransport" 
+0

感謝您的建議!我會試試這個,並讓你知道它是如何發生的。 –