Django芹菜任务在启动芹菜服务器时立即运行

Question

我需要找到如何指定一种初始的芹菜任务，它将以特殊定义的方式启动所有其他任务。这个初始任务应该在芹菜服务器启动时立即运行，并且永远不要再运行。

Answer 1

使用celeryd_after_setup或celeryd_init信号如何？

遵循文档中的示例代码：

from celery.signals import celeryd_init
@celeryd_init.connect(sender='[e-mail]')
def configure_worker12(conf=None, **kwargs):
    ...

Answer 2

我找到了这样做的方法。它有一个负面的方面——无法指定当前年份，任务将在一年又一年后运行。但通常服务器重新启动的频率要比这段时间高。

from celery.task import PeriodicTask
class InitialTasksStarter(PeriodicTask):
    starttime = datetime.now() + timedelta(minutes=1)
    run_every = crontab(month_of_year=starttime.month, day_of_month=starttime.day, hour=starttime.hour, minute=starttime.minute)
    def run(self, **kwargs):
        ....
        return True