2011-11-22 91 views
0

在這一點上,我已經閱讀了大部分rabbitmq文檔和芹菜文檔,並且多次閱讀google soo。基本上我無法找到任何我需要的信息。如何使用celery和django來運行已經在rabbitmq隊列中的任務?

我有一個扭曲的網絡服務器讀取傳遞給它的消息,並將消息放入使用pika的隊列中。這工作正常。我遇到的問題是我從這裏做的。週期性的(使用celerybeat)會發生什麼情況,我想消耗當前隊列中的內容。我遇到的最大問題是我不知道如何將任務傳遞到rabbitmq,以便芹菜(或芹菜跳動)可以分配要完成的任務。

問這個問題最簡單的方法是:我可以讀取有數據作爲主體並在django中使用該數據的隊列嗎?

任何幫助,將不勝感激。

回答

0

我不知道,如果這是任何幫助,但我用djcelery任務從Django中排隊,這個隊列兔MQ

一個單獨的Python manage.py(celeryd | celerybeat)過程中拿起排隊根據設置在Django任務

https://github.com/ask/django-celery

0

認爲我也有同樣的問題,但讓我再說一遍,以確保:

你可以使用芹菜ŧ o使用由另一個非Django,非Celery進程放入RabbitMQ的消息?例如,如果一個Java系統在購買產品時向RabbitMQ發送消息,Celery任務會對該消息做出響應並採取一些行動?

相關問題