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

Question

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

Answer 1

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

celery_once というライブラリがあり、その背後にあるメカニズムは、タスクの実行中に同じタスクを再度トリガーできないように、タスク名でタスク ロックを設定することです。

タスクがトリガーされたときに、そのタスクがすでにロックを持っていることが判明した場合、AlreadyQueued 例外は、前のタスクが実行されず、次のサイクルが到着したときにスケジュールされたタスクに非常に適しています。分散タスク サービス。相互に排他的なシナリオ。

お役に立てば幸いです。