芹菜：启动时启动任务

问题描述

我有一个任务需要在芹菜启动时启动。此任务下一次通过回调/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, ...)

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