芹菜:启动时的启动任务

Question

我有一个需要在Celery启动时启动的任务.接下来通过回调/ eta每5分钟运行一次此任务.

我找到了一些关于它的线索,但似乎没有任何东西可用于Celery 3.

谢谢你的帮助,Arnaud.

Answer 1

Celery的IRC频道上的某个人通过使用"worker_ready.connect"信号为我提供了正确的方法:http://docs.celeryproject.org/en/latest/userguide/signals.html#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, ...)

它现在就像一个魅力!