Python + Celery:防止重复执行任务



如何防止同时执行两个或多个相同的任务?

例如:如果我有一个名为 do_stuff 的任务和一个调用它的程序,则只有在当前没有其他正在运行的do_stuff实例时,它才应该被执行。

根据 DOCS:

您可以使用锁来完成此操作。

有此警告:

为了使它正常工作,您需要使用缓存后端,其中 .add 操作是原子的。 众所周知,memcached 可以很好地用于此目的。

相关内容

  • 没有找到相关文章

最新更新