ActiveJob/Resque грязный читает. Уровень изоляции транзакции

Question

У меня есть несколько работников Resque для одного и того же объекта (пользователя). После успешной обработки он должен уменьшить атрибут call_left.

Он отлично работает с perform_now (следовательно), но дает непредсказуемые результаты с perform_later (параллельно). В журналах есть коммиты с таким же числом calls_left.

Я попытался использовать метод reload и даже установить самый высокий уровень изоляции. Но все еще есть эта проблема.

Как решить?

class DataProcessJob < ActiveJob::Base 
    queue_as :default  
    def perform(user_id, profile_id) 
    User.transaction(isolation: :serializable) do 
     user = User.find(user_id).reload 
     user.data_process(profile_id) 
     user.update(calls_left: user.calls_left-1) 
    end 
    end 
end 

Answer 1

Первый вариант будет использовать блокировки (optimistic или pessimistic). Документация объясняет их различия, и вы можете выбрать тот, который подходит вашему делу. Кроме того, here is a relevant code snippet из документов, которые, вероятно, помогут вам, если вы пойдете с оптимистичной блокировкой.

def with_optimistic_retry 
    begin 
    yield 
    rescue ActiveRecord::StaleObjectError 
    begin 
     # Reload lock_version in particular. 
     reload 
    rescue ActiveRecord::RecordNotFound 
     # If the record is gone there is nothing to do. 
    else 
     retry 
    end 
    end 
end 

Второй вариант будет увеличивать calls_left поле с помощью сырой SQL строки запроса. Базовая БД будет заниматься атомными обновлениями.

---

последнее, но не менее, вы можете использовать decrement!(:calls_left) метод, чтобы сделать код более читаемым.