Celery 能让某个任务同时只能运行一个么。
有个任务在同一时间只能有一个进程执行它,假如这个任务celery 正在跑,后面再提交的就task忽略不跑了。
Celery有参数能快速设置么,还是要自己写逻辑控制。
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
有个任务在同一时间只能有一个进程执行它,假如这个任务celery 正在跑,后面再提交的就task忽略不跑了。
Celery有参数能快速设置么,还是要自己写逻辑控制。
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
接受
或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
发布评论
评论(1)
https://pypi.python.org/pypi/...
有个叫celery_once的库,背后的机制是在redis中以该任务名字设置一个任务的锁,当一个任务正在执行时,相同的任务不能再次被触发。
当任务被触发时,如果发现该任务已经有锁了,会抛出一个AlreadyQueued异常,非常适合用在上一次任务没执行,下一次周期到了,以及分布式任务服务情况下的定时任务互斥场景。
希望对你有用。