celeryd

    0熱度

    1回答

    我正在使用芹菜,rabbitmq的項目的工作。我想有權控制隊列推送任務的時間間隔(芹菜)。

    11熱度

    2回答

    我想創建一個定期任務芹菜使用django芹菜的管理界面。我有一個設置好的任務,當手動或通過腳本調用時它運行的很好。它只是不能通過celerybeat。根據調試日誌,任務在第一次檢索時設置爲enabled = False,我不知道爲什麼。 添加週期性任務並傳遞[1, False]作爲位置參數時,該任務會自動禁用,並且我看不到任何其他輸出。當沒有參數添加時,任務被執行,但立即引發異常,因爲我沒有提供所

    6熱度

    1回答

    我將芹菜作爲守護進程運行,但我有時無法優雅地停止芹菜。當我發送TERM信號並且隊列中有物品(在本例中爲service celeryd stop)時,celeryd將停止接受新的工作,並關閉所有工作進程。但是,父進程不會關閉。 我剛剛遇到了一個場景,我在兩臺單獨的工作機器上運行了芹菜:A和B.在RabbitMQ服務器上有大約1000條消息,我關閉了A,並遇到了我上面解釋的情況。 B繼續工作,但隨後停

    1熱度

    1回答

    我是新來的芹菜,可能做錯了什麼,但我已經 花了很多嘗試弄清楚如何正確配置芹菜 。 因此,在我的環境中,我有2個遠程服務器;一個是主要的(它有 公共IP地址和大部分的東西像數據庫服務器,rabbitmq 服務器和web服務器運行我的web應用程序在那裏),另一個 用於特定任務,我想從 異步調用main服務器使用芹菜。 我打算使用RabbitMQ作爲經紀人和結果後端。 芹菜配置非常簡單: CELERY

    32熱度

    3回答

    看來我的rabbitmq服務器運行時間越長,我對未確認的消息的麻煩就越多。我很樂意要求他們。事實上,似乎有一個amqp命令來執行此操作,但它只適用於您的連接正在使用的通道。我建了一個小鼠兔腳本至少嘗試一下,但我無論是失去了一些東西,或者不能做這樣(與rabbitmqctl怎麼樣?) import pika credentials = pika.PlainCredentials('***', '

    2熱度

    1回答

    我想設置與芹菜Django,所以我可以在後臺發送批量電子郵件。 我對如何將不同的組件發揮到芹菜有點困惑。我需要使用RabbitMQ嗎?我可以只用「django-kombu」來運行芹菜嗎? (http://ask.github.com/celery/tutorials/otherqueues.html#django-database) 我開始在Django的芹菜文檔「第一步和Django」(http