python - 使用 Django ORM 作为跨主机的多进程锁

Question

我在连接到公共数据库服务器的几个 Web 主机上运行 Django。该数据库包含一个简单的待处理作业表。例如

class Job(models.Model):

    name = models.CharField(max_length=255, null=False, help_text='task to do')
    worker = models.CharField(max_length=255, null=True, help_text='globally unique host name')

我将如何使用 Django 的 ORM 来查询待处理的作业（其中 worker 为空）并自动设置工作者名称，因此没有两个 Django 进程会意外地获取同一个作业（即避免竞争条件）？

理想情况下，我只想通过查询/更新在表锁中进行包装，但 Django 的 ORM 似乎没有内置此功能。

Answer 1

正如其他人所提到的，Celery 将是最好的工具。如果你不想使用 Celery：

• 如果您使用的是最新的 Django，请使用select_for_update()来查询您的 Job，然后填写 worker 字段。这就是你在 Django ORM 中想要的“表锁”。它只锁定受影响的行，因此通过允许更多并发性，它比表锁定更好。

• 如果您使用的select_for_update()是不可用的旧版本，请实施“锁定表”（就像 10 行一样简单）来保护您的关键部分。