Sidekiq任务因模型after_commit失败？如何解耦及优化？

运行PerformAndCreateFooJob任务时，Foo记录已成功创建，但Foo模型的after_commit回调抛出错误，导致整个任务失败并进入死任务队列。修复after_commit错误后重新运行任务，会再次创建Foo记录（重试时也会如此），这不符合预期。

期望结果 #

PerformAndCreateFooJob在Foo记录创建成功后即可正常完成，after_commit逻辑不应导致任务失败。

疑问 #

1. 为何after_commit会被视为该任务的一部分？
2. 是否有办法将after_commit代码与任务解耦？
3. 若无法解耦，有没有更好的模式可以采用？

代码示例 #

任务代码

class PerformAndCreateFooJob
  include Sidekiq::Job
  sidekiq_options retry: 0

  def perform = Foo.create
end

模型代码

class Foo < ApplicationRecord
  after_commit -> () { raise }
end

配图 #

1. 为何after_commit会被视为任务的一部分？ #

Foo.create会触发Active Record的完整生命周期，after_commit回调在事务提交完成后同步执行，且整个执行流程都处于PerformAndCreateFooJob的perform方法调用栈内。Sidekiq会监控任务执行过程中所有未捕获的异常，只要perform方法执行链中出现未处理错误，就会判定任务失败，因此after_commit抛出的异常会被归为任务本身的错误。

2. 将after_commit代码与任务解耦的方案 #

有两种可靠的实现方式：

• 异步化回调逻辑：把after_commit中的业务逻辑抽成独立的Sidekiq任务，在回调中异步触发。这样即使后续任务失败，也不会影响原创建任务的状态，且不会重复创建Foo记录。

  class Foo < ApplicationRecord
    after_commit :trigger_post_create_job, on: :create
  
    private
  
    def trigger_post_create_job
      FooPostCreateJob.perform_async(self.id)
    end
  end
  
  class FooPostCreateJob
    include Sidekiq::Job
  
    def perform(foo_id)
      foo = Foo.find(foo_id)
      # 原after_commit中的逻辑，例如抛出异常的操作
      raise
    end
  end
  

• 回调内捕获异常：在after_commit回调内部捕获所有异常，阻止异常冒泡到任务执行栈，从而避免任务失败。

  class Foo < ApplicationRecord
    after_commit -> do
      begin
        raise # 原回调逻辑
      rescue => e
        Rails.logger.error("Foo after_commit failed: #{e.message}\n#{e.backtrace.join("\n")}")
        # 可根据需求添加告警等操作
      end
    end
  end
  

3. 无法解耦时的替代模式 #

如果业务要求after_commit逻辑必须同步执行，可通过以下模式规避重复创建问题：

• 拆分任务职责：把“创建Foo记录”和“后续业务逻辑”拆分为两个独立任务。先执行创建任务，确认记录创建成功后，再触发后续逻辑任务。即使后续任务失败，也不会重复创建Foo记录。

  class CreateFooJob
    include Sidekiq::Job
  
    def perform
      foo = Foo.create! # 使用create!确保创建失败时任务直接报错
      FooPostCreateJob.perform_async(foo.id)
    end
  end
  
  class FooPostCreateJob
    include Sidekiq::Job
  
    def perform(foo_id)
      foo = Foo.find(foo_id)
      # 原after_commit中的同步逻辑
    end
  end
  

• 手动调用业务逻辑：移除after_commit回调，在创建任务中手动调用后续业务方法，并捕获该方法的异常，确保记录创建成功后任务正常完成。

  class PerformAndCreateFooJob
    include Sidekiq::Job
    sidekiq_options retry: 0
  
    def perform
      foo = Foo.create
      begin
        foo.run_post_create_logic
      rescue => e
        Rails.logger.error("Post create logic failed: #{e.message}")
      end
    end
  end
  
  class Foo < ApplicationRecord
    def run_post_create_logic
      raise # 原回调逻辑
    end
  end
  

内容的提问来源于stack exchange，提问作者aaronkelton