django-celery

    1熱度

    1回答

    我可以單獨檢查並刪除Celery/RabbitMQ任務嗎？

    我正在運行Django + Celery + RabbitMQ。在修改某些任務名稱後，我開始獲得「未註冊的任務」KeyErrors，即使在使用該鍵從Django Celery Beat的Periodic tasks表中刪除任務並重新啓動了Celery worker之後。 原來Celery/RabbitMQ tasks are persistent。我最終通過reimplementing the l
    django rabbitmq celery django-celery celerybeat 2017-08-28

    1熱度

    1回答

    如何擺脫仍在Celery/RabbitMQ隊列中的遺留任務？

    我正在運行Django + Celery + RabbitMQ。在修改某些任務名稱後，我開始獲得「未註冊的任務」KeyErrors，即使在使用該鍵從Django Celery Beat的Periodic tasks表中刪除任務並重新啓動了Celery worker之後。他們persist甚至在running with the --purge option之後。 我該如何擺脫它們？
    django rabbitmq celery django-celery celerybeat 2017-08-28

    0熱度

    2回答

    芹菜+ Python：在另一個任務中排隊耗時的任務

    我想查詢一個api（這很耗時），有很多項目（〜100），但不是一次全部。相反，我想在查詢之間稍微延遲一點。 我現在有是獲取異步，並通過查詢，並在每次迭代後迭代執行的任務等待一段時間： @shared_task def query_api_multiple(values): delay_between_queries = 1 query_results = []
    python celery django-celery 2017-09-03

    0熱度

    1回答

    Django芹菜和rabbitmq不工作，直到重新啓動

    我有django，芹菜和rabbitmq問題。 我使用芹菜向FCM設備發送消息，但問題是芹菜不會運行該FCM命令發送消息，直到我重新啓動芹菜服務器。 當我重新啓動芹菜，並再次嘗試，仍然相同，我需要在每次行動後再次重新啓動它。 示例代碼： from __future__ import absolute_import, unicode_literals from celery import sha
    python django rabbitmq celery django-celery 2017-09-13

    0熱度

    3回答

    我該如何防止相同的任務在另一個上執行？

    我有一個任務，從API中提取數據，然後對數據庫（SQLite）進行系統自動化（刪除，重命名......）。我將任務設置爲每5分鐘執行一次。但是，有時這項任務需要5分鐘才能完成，因此兩項任務並行運行。這不好，因爲SQLite數據庫在0分鐘內被鎖定到任務。 怎樣纔可以有，要麼， 任務不會，除非前面的任務已經完成或執行 第二個任務排隊等候和執行後直接0分鐘任務完成了嗎？ 我試圖使用全局布爾值來防止任務在
    python django celery django-celery 2017-09-25

    2熱度

    2回答

    如何重新啓動芹菜Wroker由Supervisord運行

    我使用supervisord運行芹菜生產。我的主管配置如下。 [program:celeryd] command=%(ENV_PROJECT_PATH)s/scripts/celery_worker.sh stdout_logfile=%(ENV_PROJECT_PATH)s/celeryd.log stderr_logfile=%(ENV_PROJECT_PATH)s/celeryd.lo
    python django celery django-celery supervisord 2017-10-18

    0熱度

    2回答

    芹菜任務隊列不能與rabbitmq一起工作

    芹菜任務成功執行無隊列 設置。 BROKER_URL = "amqp://user:[email protected]:5672/test" # Celery Data Format CELERY_ACCEPT_CONTENT = ['application/json'] CELERY_TASK_SERIALIZER = 'json' CELERYD_TASK_SOFT_TIME_LIM
    python rabbitmq celery django-celery 2017-09-15

    0熱度

    2回答

    將參數傳遞給Celery任務的on_failure方法

    我正在創建一個自定義Celery任務類，以覆蓋在任務達到最大重試次數（on_failure）時發生的情況。如果任務失敗，我需要更新用戶模型的狀態。 下面是我的自定義任務類： class ReadyTask(Task): def run(self, user): try: user.get_results() except Exception as
    python task celery scheduled-tasks django-celery 2017-07-28

    -1熱度

    1回答

    導入錯誤：沒有模塊名爲task.control

    我試圖導入revoke方法芹菜，取消與一個任務： from celery.task.control import revoke 但這引發錯誤： ImportError: No module named task.control 爲什麼我得到這個錯誤？我找不到有關Celery刪除或重構此方法的任何文檔。 我使用的是celery==3.1.18，我無法升級它，因爲我使用的Django版本依賴於
    django celery django-celery 2017-07-31

    0熱度

    2回答

    讓用戶創建芹菜週期性任務

    我想問你在django應用程序中使用芹菜和redis的情況。我正在學習芹菜約2天，我仍然有點困惑：/我已經安裝了芹菜和redis，它工作得很好。我的問題是，我希望用戶創建，更新和暫停週期性任務。我讀過這篇文章 - http://kindshofer.net/2016/11/19/dynamically_adding_a_periodic_task_to_celery.html和這個問題 - How
    django redis celery django-celery periodic-task 2017-09-19
最新問題