私はdelayed_jobプロセスかどうかを確認してください

Question

私はdelayed_jobを使用するRailsアプリケーションを持っています。私はdelayed_jobプロセスにいるかどうかを検出したい。何かのように

if in_delayed_job? 
    # do something only if it is a delayed_job process... 
else 
    # do something only if it is not a delayed_job process... 
end 

しかし、私はどのように把握することはできません。これは私が今使っているものです：@MrDanAが言ったように

IN_DELAYED_JOB = begin 
    basename  = File.basename $0 
    arguments  = $* 
    rake_args_regex = /\Ajobs:/ 

    (basename == 'delayed_job') || 
    (basename == 'rake' && arguments.find{ |v| v =~ rake_args_regex }) 
end 

別の解決策は、次のとおりです。

$ DELAYED_JOB=true script/delayed_job start 
# And in the app: 
IN_DELAYED_JOB = ENV['DELAYED_JOB'].present? 

が、彼らは私見弱いソリューションです。誰かがより良い解決策を提案できますか？

Answer 1

私がこれらを処理する方法は、パラノイドワーカーです。私は私のサイトにアップロードされたビデオのトランスコードにdelayed_jobを使用します。ビデオのモデル内では、デフォルトで0/nullに設定されているvideo_processingというフィールドがあります。ビデオがdelayed_job（ビデオファイルの作成時または更新時）によってトランスコードされるたびに、delayed_jobからのフックが使用され、ジョブが開始されるたびにvideo_processingが更新されます。ジョブが完了したら、完成したフックは、私は多分このような何かをvideo.video_processing? ? "Video Transcoding in Progress" : "Video Fished Transcoding"

Answer 2

を行うことができます私の見解/コントローラでは0

にフィールドを更新します。あなたのクラスにフィールドを追加し、あなたが遅延のジョブからすべての作業を行うメソッドを呼び出すときにそれを設定します。

遅れの仕事から：ここで

class User < ActiveRecord::Base 
    attr_accessor :in_delayed_job 

    def queue_calculation_request 
    Delayed::Job.enqueue(CalculationRequest.new(self.id)) 
    end 

    def do_the_work 
    if (in_delayed_job) 
     puts "Im in delayed job" 
    else 
     puts "I was called directly" 
    end 
    end 

    class CalculationRequest < Struct.new(:id) 
    def perform 
     user = User.find(id) 
     user.in_delayed_job = true 
     user.do_the_work 
    end 

    def display_name 
     "Perform the needeful user Calculations" 
    end 
    end 
end 

は、それがどのように見えるかです

Worker(host:Johns-MacBook-Pro.local pid:67020)] Starting job worker 
Im in delayed job 
[Worker(host:Johns-MacBook-Pro.local pid:67020)] Perform the needeful user Calculations completed after 0.2787 
[Worker(host:Johns-MacBook-Pro.local pid:67020)] 1 jobs processed at 1.5578 j/s, 0 failed ... 

コンソールから

user = User.first.do_the_work 
    User Load (0.8ms) SELECT "users".* FROM "users" WHERE "users"."id" = $1 LIMIT 1 [["id", 101]] 
I was called directly 

Answer 3

どうENV [ 'PROC_TYPE']について
のみHerokuのといえば...しかし、あなたは労働者のダイナモをしているとき、これは「労働者」に設定されている は、私が「私はDJにいるよ」

Answer 4

これは私のために働く私のようにそれを使用します。

def delayed_job_worker? 
    (ENV["_"].include? "delayed_job") 
end 

Unixは、現在のコマンドに "_"環境変数を設定します。

"not_a_delayed_job"と呼ばれるbinスクリプトがあれば間違いでしょうが、そうしないでください。