問(wèn)題描述

我嘗試過(guò)django-celery-beat，在admin后臺(tái)添加任務(wù)，可以實(shí)現(xiàn)動(dòng)態(tài)添加任務(wù)但要重啟celery beat才生效，請(qǐng)問(wèn)，有其他方試嗎？

問(wèn)題解答

無(wú)法動(dòng)態(tài)添加，必須重啟 beat。

ask 回答過(guò)原因了 #3493

有個(gè)思路，你可以考慮，我目前也在嘗試這個(gè)方法，處于摸石過(guò)河階段。celery是支持定時(shí)任務(wù)，但是不符合我的需求，我需要像linux下的crontab這樣動(dòng)態(tài)添加定時(shí)任務(wù)，我也看了django-celery-beat，因?yàn)橛玫氖荈lask，發(fā)現(xiàn)不值得參考實(shí)現(xiàn)，所以一直在看文檔搜資料，終于被我找到一種方式，celery的apply_async這個(gè)函數(shù)非常有用，它有個(gè)eta參數(shù)，它的簡(jiǎn)化使用是countdown，但是eta的威力是很巨大的，因?yàn)樗唤邮躣atetime對(duì)象，比如你給定一個(gè)任務(wù)在2017-05-02 20:0:0執(zhí)行，你可以這樣使用:

job.apply_async(args=args, kwarg=kwargs, eta=datetime(2017,5,2,20,0,0))

是不是很少用，假如我有一個(gè)任務(wù)需要每天晚上八點(diǎn)執(zhí)行，我可以利用這個(gè)eta參數(shù)實(shí)現(xiàn)。偽代碼如下：

時(shí)間規(guī)則 = ’每天晚上八點(diǎn)執(zhí)行’第一次調(diào)用任務(wù)，先計(jì)算最近的執(zhí)行時(shí)間，作為eta的參數(shù)，調(diào)用apply_async函數(shù)，然后第一次任務(wù)執(zhí)行成功，得到上次任務(wù)的eta參數(shù)值，在天的值上加一，然后把新的執(zhí)行時(shí)間作為eta的參數(shù)再次調(diào)用apply_async函數(shù)，這里省略了很多判斷，自行腦補(bǔ)。循環(huán)往復(fù)，是不是一直按每天晚上八點(diǎn)執(zhí)行。

這里有個(gè)非常重要的點(diǎn)是如何在任務(wù)執(zhí)行成功的時(shí)候計(jì)算下一次的執(zhí)行時(shí)間，做法如下

class MyTask(Task): def on_success(self, retval, task_id, args, kwargs):print ’task done: {0}’.format(retval)return super(MyTask, self).on_success(retval, task_id, args, kwargs) def on_failure(self, exc, task_id, args, kwargs, einfo):print ’task fail, reason: {0}’.format(exc)return super(MyTask, self).on_failure(exc, task_id, args, kwargs, einfo)@app.task(base=MyTask)def add(x, y): return x + y

它提供了任務(wù)執(zhí)行成功和失敗的函數(shù)，我們只要在此基礎(chǔ)上重寫(xiě)就可以了，我說(shuō)的只是最核心的部分，具體怎么做有很多方法，