2016-07-27 31 views
1

私はRORアプリケーションに取り組んでいます。 私は ためsidekiqsidekiq-schedulerで30秒ごとにスケジュールする方法

を使用して、30秒ごとにメソッドを呼び出す必要があり、私はここではこれらの宝石

# sidekiq 
gem 'sidekiq', '~> 3.3.0' 
# sidekiq scheduler 
gem 'sidekiq-scheduler', '~> 2.0' 

を使用していた機能要件を、持っているが、私のscheduler.ymlファイルコードです。

perform: 
    every: ["30s"] 
    class: Aggregator 
    queue: aggregation 
    description: "This job will create Aggregate data." 

ここは、Workersフォルダ内のアグリゲータクラスです。

class Aggregator 
    include Sidekiq::Worker 
    sidekiq_options :backtrace => 5, :retry => false 

    def perform 
    end_time = time - (time.sec%30).seconds 
    puts "ROUNDING TO 30 SEC" 
    puts end_time  
    Session.create_aggregate_data(end_time) 
    end 
end 

私がsidekiqログをチェックしているとき、それはperformメソッドに当たっていません。しかしアグリゲータクラスはここ

はログです呼ばなっている。..

2016-07-27T10:19:59.436Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:20:29.641Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:20:59.836Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:21:30.009Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:22:00.204Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:22:30.507Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:23:00.509Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:23:30.760Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
2016-07-27T10:24:01.068Z 15117 TID-1qjnlu INFO: queueing Aggregator (perform) 
+0

を設定しなかった場合のデフォルトにキューを設定してくださいキューに入れられていても処理されていません。愚かな質問:あなたはサイドキックを始めましたか? 'bundle exec sidekiq'? – MrWillihog

+0

応答ありがとう.. @MrWillihog。 これらのログは、私が 'sidekiq'コマンドを実行したときに来ます。 – SaiBharath

答えて

0

ジョブがあるので、デフォルト以外のキューに

queue: default 
+2

いいえ、ワーカーはワーカーで終了する必要はありません。それは命名規則です。 –

関連する問題