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

Question

我在连接到公共(public)数据库服务器的多个 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 为 null)并自动设置 worker 名称，这样两个 Django 进程就不会意外地获取同一个作业(即避免竞争条件)？

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

Answer 1

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

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

• 如果您使用的是 select_for_update() 不可用的旧版本，请实现“锁定表”(简单至 10 行)以保护您的关键部分。