Ruby 错误处理：拯救子类中的异常

Question

我有一个 Adapter 类的集合，这些类连接到各种 API 等等。以下是每个适配器如何设置的简单通用示例：

class AmazonAdapter
    include Sidekiq::Worker
    def perform(id)
        get_results_from_api(id)
    end
end

class WalmartAdapter
    include Sidekiq::Worker
    def perform(id)
        get_results_from_api(id)
    end
end

所以一般来说，通过调用AmazonAdapter.new(500)，它将连接到 API 并根据您作为 ID 传入的内容返回结果。这都是 Sidekiq 收集过程的一部分，并作为后台作业运行，因此当出现问题时它不一定会抛出明显的异常或错误来提醒我。

我想使用 AirBrake 的通知系统在 API 未正确连接或抛出任何其他错误时通知我，但不会停止收集过程或 sidekiq。我希望将错误处理和通知系统纳入主流。

我的一些想法是创建一个子类可以继承的 ParentClass，看起来类似于：

class Adapter
    include Sidekiq::Worker
    def perform(id)
        begin
            #execute subclass perform method
        rescue Exception => e
            Airbrake.notify(e)
        end
    end
end

但我不确定解决此问题的最佳方法。我真的可以在这方面使用一些建议或帮助，谢谢！

Answer 1

Sidekiq 中存在一个瓶颈，它基本上执行所有操作：Sidekiq::Processor#execute_job，它接收两个参数 (worker, cloned_args) 并随后调用 worker.perform(*cloned_args)。所以，为了你的目的，我会在模块前面加上：

Sidekiq::Processor.prepend(Module.new do
  def execute_job(worker, cloned_args)
    super # CALL ORIGINAL
  rescue => e # NEVER RESCUE FROM EXCEPTION!!!
    Airbrake.notify(e) # NOTIFY
    raise e # RE-RAISE SO SIDEKIQ DOES HIS JOB
  end
end)

在你的第一份工作之前调用它，你就完成了：在 Sidekiq 调用工作人员期间发生的所有错误现在都被空气制动了。

希望对你有帮助。

Answer 2

我使用类似的构造来提醒我某些 chron 作业中的失败并 ping 一个松弛通道，但好的部分是它不需要继承！一个天真的版本看起来像这样：

class AirbrakeNotifier
  def safe_run
    yield
  rescue StandardError => e
    log_error(e)
    raise e
  end

  private

  def log_error(e)
    # do your logging here
  end
end

然后你的工人看起来像这样：

class AmazonAdapter
  include Sidekiq::Worker

  def perform(id)
    AirbrakeNotifier.new.safe_run { get_results_from_api(id) }
  end
end

这为您提供了更大的灵活性，可以根据您想要的每个类、每个进程或您能想到的不同方式配置日志记录！