本文介绍了芹菜:启动时启动任务的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着跟版网的小编来一起学习吧!
问题描述
我有一个任务需要在芹菜启动时启动。此任务下一次通过回调/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, ...)
现在它就像护身符一样起作用了!
这篇关于芹菜:启动时启动任务的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持跟版网!
本站部分内容来源互联网,如果有图片或者内容侵犯了您的权益,请联系我们,我们会在确认后第一时间进行删除!