django芹菜：如何設置任務以特定的時間間隔以編程方式運行

Question

我發現我可以將任務設置爲在特定時間從here以特定時間間隔運行，但這隻在任務聲明期間完成。如何將任務設置爲動態定期運行？

Answer 1

時間表是derived from a setting，因此在運行時似乎是不可變的。

您可以使用Task ETAs或許可以完成要查找的內容。這保證你的任務不會在之前運行所需的時間，但不會承諾在指​​定的時間運行任務 - 如果工作人員在指定的ETA超載，任務可能會在稍後運行。

如果限制是不是一個問題，你可以寫這將首先運行本身就像一個任務：

@task 
def mytask(): 
    keep_running = # Boolean, should the task keep running? 
    if keep_running: 
     run_again = # calculate when to run again 
     mytask.apply_async(eta=run_again) 
    # ... do the stuff you came here to do ... 

這種方法的主要缺點是，你是依靠taskstore記住任務在飛行中。如果其中一個在發射下一個失敗之前失敗，那麼該任務將永不再運行。如果您的經紀人沒有堅持到磁盤並且死亡（將所有的飛行任務與它一起），那麼這些任務都不會再次運行。

你可以通過某種事務日誌記錄和週期性的「保姆」任務來解決這些問題，該任務的任務是找到這樣的重複任務，以避免死亡並使其復活。

如果我必須實現你所描述的內容，我認爲這是我將如何處理它。

Answer 2

看到這裏http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html

我認爲你不能讓它動態...最好的辦法是創建任務的任務：比如你要運行的東西X秒後即可創建新的d

具有x秒延遲的任務並且在此任務中爲N * X秒延遲創建另一個任務...

Answer 3

celery.task.base.PeriodicTask定義is_due它決定了下一次運行的時間。您可以重寫此函數以包含您的自定義動態運行邏輯。在這裏看到的文檔：http://docs.celeryproject.org/en/latest/reference/celery.task.base.html?highlight=is_due#celery.task.base.PeriodicTask.is_due

一個例子：

import random 
from celery.task import PeriodicTask 

class MyTask(PeriodicTask): 

    def run(self, **kwargs): 
     logger = self.get_logger(**kwargs) 
     logger.info("Running my task") 

    def is_due(self, last_run_at): 
     # Add your logic for when to run. Mine is random 
     if random.random() < 0.5: 
      # Run now and ask again in a minute 
      return (True, 60) 
     else: 
      # Don't run now but run in 10 secs 
      return (True, 10) 

Answer 4

這會幫助你一些... http://celery.readthedocs.org/en/latest/faq.html#can-i-change-the-interval-of-a-periodic-task-at-runtime

一旦你定義一個自定義計劃，將其分配給你的任務，asksol有如上所述。

CELERYBEAT_SCHEDULE = {  
    "my_name": { 
     "task": "myapp.tasks.task", 
     "schedule": myschedule(),  
    } 
} 

您可能還需要修改CELERYBEAT_MAX_LOOP_INTERVAL如果你想你的日程安排更經常超過每五分鐘更新一次。