在這一點上,我已經閱讀了大部分rabbitmq文檔和芹菜文檔,並且多次閱讀google soo。基本上我無法找到任何我需要的信息。如何使用celery和django來運行已經在rabbitmq隊列中的任務?
我有一個扭曲的網絡服務器讀取傳遞給它的消息,並將消息放入使用pika的隊列中。這工作正常。我遇到的問題是我從這裏做的。週期性的(使用celerybeat)會發生什麼情況,我想消耗當前隊列中的內容。我遇到的最大問題是我不知道如何將任務傳遞到rabbitmq,以便芹菜(或芹菜跳動)可以分配要完成的任務。
問這個問題最簡單的方法是:我可以讀取有數據作爲主體並在django中使用該數據的隊列嗎?
任何幫助,將不勝感激。