如何使ExceptionNotifier在Rails 3中使用delayed_job？

Question

我想讓ExceptionNotifier在延遲作業中發生異常時發送電子郵件，就像其他異常一樣。我怎樣才能做到這一點？

Answer 1

我這樣做是使用Rails 3.2.6，3.0.3的delayed_job和exception_notification 2.6.1寶石

# In config/environments/production.rb or config/initializers/delayed_job.rb 

# Optional but recommended for less future surprises. 
# Fail at startup if method does not exist instead of later in a background job 
[[ExceptionNotifier::Notifier, :background_exception_notification]].each do |object, method_name| 
    raise NoMethodError, "undefined method `#{method_name}' for #{object.inspect}" unless object.respond_to?(method_name, true) 
end 

# Chain delayed job's handle_failed_job method to do exception notification 
Delayed::Worker.class_eval do 
    def handle_failed_job_with_notification(job, error) 
    handle_failed_job_without_notification(job, error) 
    # only actually send mail in production 
    if Rails.env.production? 
     # rescue if ExceptionNotifier fails for some reason 
     begin 
     ExceptionNotifier::Notifier.background_exception_notification(error) 
     rescue Exception => e 
     Rails.logger.error "ExceptionNotifier failed: #{e.class.name}: #{e.message}" 
     e.backtrace.each do |f| 
      Rails.logger.error " #{f}" 
     end 
     Rails.logger.flush 
     end 
    end 
    end 
    alias_method_chain :handle_failed_job, :notification 
end 

這可能是一個好主意，在所有環境中加載此代碼之前趕上捆綁更新等錯誤後他們達到生產。我通過使用config/initializers/delayed_job.rb文件來完成此操作，但您可以複製每個config/environments/*環境的代碼。

另一個技巧是調整延遲作業配置有點默認情況下，你可能會在作業失敗時得到大量重複的異常郵件。

# In config/initializers/delayed_job_config.rb 
Delayed::Worker.max_attempts = 3 

更新我有一些問題delayed_job守護默默退出，它原來是當ExceptionNotifier無法發送郵件，沒有人獲救例外。現在代碼解救並記錄它們。

Answer 2

對於exception_notification 3.0.0變化：

ExceptionNotifier::Notifier.background_exception_notification(error) 

到：

ExceptionNotifier::Notifier.background_exception_notification(error).deliver 

Answer 3

簡單的和更新的答案：

# Chain delayed job's handle_failed_job method to do exception notification 
Delayed::Worker.class_eval do 
    def handle_failed_job_with_notification job, error 
    handle_failed_job_without_notification job, error 
    ExceptionNotifier.notify_exception error, 
     data: {job: job, handler: job.handler} rescue nil 
    end 
    alias_method_chain :handle_failed_job, :notification 
end 

和測試與控制檯：

Delayed::Job.enqueue (JS=Struct.new(:a){ def perform; raise 'here'; end }).new(1) 

Answer 4

添加到@MattiasWadman答案，因爲exception_notification 4.0 there's a new way to handle manual notify。因此，而不是：

ExceptionNotifier::Notifier.background_exception_notification(error) 

使用

ExceptionNotifier.notify_exception(error) 

Answer 5

另一種方式來處理異常（如放一個初始化）：

class DelayedErrorHandler < Delayed::Plugin 

    callbacks do |lifecycle| 

    lifecycle.around(:invoke_job) do |job, *args, &block| 

     begin 
     block.call(job, *args) 
     rescue Exception => e 

     # ...Process exception here... 

     raise e 
     end 
    end 
    end 
end 

Delayed::Worker.plugins << DelayedErrorHandler