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 

두 번째 옵션은 원시 SQL 문자열 쿼리를 사용하여 calls_left 필드를 증가하는 것입니다. 기본 DB는 원자 적 업데이트를 처리합니다.

---

마지막으로,하지만 적어도, 당신은 당신의 코드를보다 쉽게 ​​읽을 수 있도록 decrement!(:calls_left) 방법을 사용할 수 있습니다.