芹菜：启动时启动任务

问题描述

我有一个任务需要在芹菜启动时启动。此任务下一次通过回调/ETA每5分钟运行一次。

我找到了一些关于它的线索，但在芹菜3上似乎没有奏效的线索。

感谢您的帮助， 阿诺德。

推荐答案

芹菜irc频道的某个人通过使用"；worker_ready.connect"；信号：http://docs.celeryproject.org/en/latest/userguide/signals.html#worker-ready

from celery.signals import worker_ready

@worker_ready.connect
def at_start(sender, **k):
    with sender.app.connection() as conn:
         sender.app.send_task('app.modules.task', args,connection=conn, ...)

现在它就像护身符一样起作用了！

这篇关于芹菜：启动时启动任务的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持跟版网！