有个任务在同一时间只能有一个进程执行它,假如这个任务celery 正在跑,后面再提交的就task忽略不跑了。Celery有参数能快速设置么,还是要自己写逻辑控制。
拥有18年软件开发和IT教学经验。曾任多家上市公司技术总监、架构师、项目经理、高级软件工程师等职务。 网络人气名人讲师,...
https://pypi.python.org/pypi/...
有个叫celery_once的库,背后的机制是在redis中以该任务名字设置一个任务的锁,当一个任务正在执行时,相同的任务不能再次被触发。
当任务被触发时,如果发现该任务已经有锁了,会抛出一个AlreadyQueued异常,非常适合用在上一次任务没执行,下一次周期到了,以及分布式任务服务情况下的定时任务互斥场景。
希望对你有用。
https://pypi.python.org/pypi/...
有个叫celery_once的库,背后的机制是在redis中以该任务名字设置一个任务的锁,当一个任务正在执行时,相同的任务不能再次被触发。
当任务被触发时,如果发现该任务已经有锁了,会抛出一个AlreadyQueued异常,非常适合用在上一次任务没执行,下一次周期到了,以及分布式任务服务情况下的定时任务互斥场景。
希望对你有用。