如何防止 Sidekiq 并行修改数据库

Question

我有一个工作人员试图根据某些条件为照片找到匹配项。每张照片都有一个独特的匹配。我编写了这样的代码：

class PhotoDeliveryWorker
include Sidekiq::Worker

def perform(photo_id)
  photo = Photo.find(photo_id)
  unless photo.match
    matches = Photo.where(some_condition: "some_value")
    match = matches.first

    if match
      # Do something to photo
      photo.match = match

      if photo.save
        match.some_condition = "another_value"
      else
        schedule photo_id
      end
    else
      # Couldn't find a match
      schedule photo_id
    end
  end
end
private
def schedule(photo_id)
  PhotoDeliveryWorker.perform_in 1.hours, photo_id
end
end

如您所见，worker 获取第一个通过条件的模型对象，然后更改match 以将其从未来的worker 匹配列表中排除。

问题是当几个工人同时执行时，他们都得到相同的matches 列表并因此修改相同的实体。但我需要为每张照片单独匹配。

我该如何解决？

附加信息：

问：为什么我使用工人？

A：如果找不到匹配项，我需要稍后重试。

问：为什么我要用多线程的 Sidekiq？

A：我需要尽快处理照片。

也许我可以在每个人的开头获得当前活跃工人的数量，并参加第 n 场比赛而不是第一次比赛。但是那个解决方案有点味道，不是吗？

更新：

附加问题：我可以使用一些关于 ActiveRecord 锁定的东西来解决这个问题吗？我对with_lock 和所有这些东西不是很熟悉。

Answer 1

解决您的问题的一个非常简单的方法是将工作量分开，这样工人就不会互相干扰。

如果你有 2 名工人，你可以给他们编号，然后对 id photo.id % 2 进行取模。这样你就只能得到 0 和 1。编号为 0 的工人仅在他的批次上工作，编号为 1 的工人在另一个上工作。通过增加模数，您可以增加任意数量的工人。