python - 在 celerybeat 中一次只运行一个任务

Question

我有一个任务，我使用 celerybeat 每分钟执行一次。它工作正常。但有时，任务的运行时间比一分钟多几秒钟，因为任务的两个实例都在运行。这会导致一些竞争条件把事情搞砸。

我可以(而且可能应该)修复我的任务以正常工作，但我想知道 celery 是否有任何内置方法来确保这一点。我粗略的 Google 搜索和 RTFM 没有产生任何结果。

Answer 1

你可以 add a lock ，使用诸如 memcached 之类的东西或仅使用您的数据库。