python - Celery 能让某个任务同时只能运行一个么。

Question

有个任务在同一时间只能有一个进程执行它，假如这个任务celery 正在跑，后面再提交的就task忽略不跑了。
Celery有参数能快速设置么，还是要自己写逻辑控制。

Answer 1

https://pypi.python.org/pypi/...

有个叫celery_once的库，背后的机制是在redis中以该任务名字设置一个任务的锁，当一个任务正在执行时，相同的任务不能再次被触发。

当任务被触发时，如果发现该任务已经有锁了，会抛出一个AlreadyQueued异常，非常适合用在上一次任务没执行，下一次周期到了，以及分布式任务服务情况下的定时任务互斥场景。

希望对你有用。