我有一个任务需要在 Celery 启动时启动。接下来，该任务将通过回调/eta 每 5 分钟运行一次。
我找到了一些关于它的线程，但似乎没有任何内容可以在 Celery 3 上工作。
感谢您的帮助，
阿诺。
Celery 的 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, ...)
现在它就像一个魅力！
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
