Sidekiqは引数をperformメソッドにどのように渡しますか？

Question

私はこのSidekiq労働者を持っている：

class DealNoteWorker 
    include Sidekiq::Worker 
    sidekiq_options queue: :email 

    def perform(options = {}) 
    if options[:type] == "deal_watch_mailer" 
     deal_watchers = DealWatcher.where("deal_id = ?", options[:deal_id]) 

     deal_note = DealNote.find(options[:deal_note_id]) 

     current_user = User.find(options[:current_user_id]) 

     deal_watchers.each do |deal_watcher| 
     unless deal_watcher.user_id == options[:current_user_id] 
      # Tell the DealWatchMailer to send emails to ALL watchers advising of change to deal 
      if deal_watcher.user.active 
      DealWatchMailer.deal_watch_email(deal_watcher, nil, deal_note, current_user, options[:url]).deliver 
      end 
     end 
     end 
    elsif options[:type] == "deal_note_mailer" 
     options[:user_ids].each do |id| 
     if DealWatcher.where("deal_id = ? and user_id =?", options[:deal_id], id).count == 0 
      deal_note = Deal.find(options[:deal_note_id]) 
      user = User.find_by_id(id) 
      DealNoteMailer.deal_note_email(deal_note, user, options[:url]).deliver 
     end 
     end 
    end 
    end 
end 

は私がperform_asyncメソッドにハッシュを渡すが、私はperformメソッドに転送パラメータがperform_asyncに渡されたものと同じタイプではないと思います。私はユーザlogger.infoとpに問題をデバッグしようとしましたが、何も出力されませんでした...

ジョブは電子メールキューに追加されますが、決して処理されません。

class DealNoteWorker 
    include Sidekiq::Worker 

    def perform(deal_id, deal_note_id, current_user_id, url) 
    deal_watchers = DealWatcher.where("deal_id = ?", deal_id) 

    deal_note = DealNote.find(deal_note_id) 

    current_user = User.find(current_user_id) 

    deal_watchers.each do |deal_watcher| 
     unless deal_watcher.user_id == current_user_id 
     # Tell the DealWatchMailer to send emails to ALL watchers advising of change to deal 
     if deal_watcher.user.active 
      DealWatchMailer.deal_watch_email(deal_watcher, nil, deal_note, current_user, url).deliver 
     end 
     end 
    end 
    end 
end 

：私も、私は以下の労働者が働くことを事実として知っている...しかし、何もいずれかの出力なかった（第一の方法の行に）

をperform方法で例外を発生させることを試みました問題はハッシュパラメータ（オプション）にあります。私は何を間違えていますか？

Answer 1

電子メールと呼ばれるキューを使用しているので、sidekiq -q emailを実行する必要があります。

Answer 2

Sidekiq documentationから：文字列、整数、浮動小数点、ブール値、ヌル、配列とハッシュ：あなたはperform_asyncに渡す

引数は、単純な JSONデータ型で構成されなければなりません。 SidekiqクライアントAPIは、JSON.dumpを使用してデータをRedisに送信します。 Sidekiqサーバーは、JSONデータをRedisから取得し、JSON.loadを使用して データをRubyタイプに変換してから、performメソッドに渡します。 シンボルや複雑なRubyオブジェクト（日付や時刻など）を として渡さないでください。ダンプ/ロード往復で正常に機能しません。

は、コンソール上でこれを見ることができます：

> options = { :a => 'b' } 
> how_sidekiq_stores_the_options = JSON.dump(options) 
> how_sidekiq_loads_the_options = JSON.load(how_sidekiq_stores_the_options) 
> how_sidekiq_stores_the_options == how_sidekiq_loads_the_options 
    false 

あなたoptionsハッシュのキーとしてシンボルを使用しているように見えます。文字列キーに切り替えると機能します。