有个任务在同一时间只能有一个进程执行它,假如这个任务celery 正在跑,后面再提交的就task忽略不跑了。Celery有参数能快速设置么,还是要自己写逻辑控制。
三叔2016-11-02 11:34:54
https://pypi.python.org/pypi/...
有个叫celery_once的库,背后的机制是在redis中以该任务名字设置一个任务的锁,当一个任务正在执行时,相同的任务不能再次被触发。
当任务被触发时,如果发现该任务已经有锁了,会抛出一个AlreadyQueued异常,非常适合用在上一次任务没执行,下一次周期到了,以及分布式任务服务情况下的定时任务互斥场景。
希望对你有用。