Delayed_Job: नौकरी मेटाडेटा और/या डुप्लिकेट नौकरियों से परहेज करना

Question

मैं कस्टम नौकरी कक्षा में run_at डेटाटाइम प्राप्त करने का प्रयास कर रहा हूं। मेरे कोड इस तरह दिखता है:

class MyCustomJob < Struct.new(:my_object) 

    def perform 
    if self.run_at == my_object.start_time 
     # process the job 
    end 
    end 

end 

मैं भी एक Delayed::Job.find(self) की कोशिश की, लेकिन कोई किस्मत थी। पहले से

धन्यवाद

Answer 1

जब आप काम बनाने के इस संभाल चाहिए:

priority = 0 
    run_time = my_object.start_time 
    Delayed::Job.enqueue(MyCustomJob.new(my_object), priority, run_time) 

https://github.com/tobi/delayed_job/wiki

अपनी नौकरी की उम्मीद समय में नहीं चल रहे हैं, तो आप उन्हें यूटीसी के लिए समय निर्धारण किया जा सकता है :

http://www.gregbenedict.com/2009/08/19/is-delayed-job-run_at-datetime-giving-you-fits/

एक मौजूदा जे के लिए कतार जाँच करने के लिए ओब - आप निम्न कर सकता है:

class MyCustomJob < Struct.new(:object_id) 

    def self.exists?(object_id) 
    Delayed::Job.where(['handler = ? and failed_at is null',handler(object_id)]).count(:all) > 0 
    end 

    def self.handler(object_id) 
    "--- !ruby/struct:MyCustomJob \nobject_id: #{object_id}\n" 
    end 

    def perform 
    my_object = MyObject.find(object_id) 
    my_object.do_stuff 
    end 
end 

तो बस कतार से पहले MyCustomJob.exists?(my_object.id) लिए जाँच करें।

यह एक हैक का थोड़ा सा है - आवश्यकतानुसार handler विधि संपादित करें। मैं विलंब_jobs तालिका को क्लीनर कोड बनाने के लिए कक्षा/object_id रखने के लिए संशोधित करता हूं और यदि आपकी नौकरियां तालिका बड़ी है या आप अन्य प्रकार की नौकरियों के साथ ऐसा करते हैं तो अधिक कुशल टेबल स्कैन करें।

यह सवाल भी प्रासंगिक लग रहा है:

How to cancel scheduled job with delayed_job in Rails?

Answer 2

आप अपने कस्टम काम पर विधि से पहले एक को परिभाषित है, तो कर्मी आप प्रदर्शन कॉल करने से पहले देरी काम उदाहरण पारित करेंगे:

class MyCustomTask 

    def before(job) 
    @job = job 
    end 

    def perform 
    # has access to @job object. 
    # You may need to call @job.reload to see in-flight changes to object in the database. 
    end 
end