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 

第2のオプションは、生のSQL文字列クエリを使用してcalls_leftフィールドを増分することです。基盤となるDBは原子的な更新を扱うでしょう。

---

最後に、decrement!(:calls_left)メソッドを使用すると、コードを読みやすくすることができます。