समांतर साइडकीक श्रमिकों के लिए एक और विधि कॉल करने से पहले सभी को पूरा करने के लिए कैसे प्रतीक्षा करें?

Question

मेरे पास कई कर्मचारी हैं जो साइडकीक का उपयोग करके चलाए जा रहे हैं और सिडेटिक का उपयोग करके निर्धारित हैं। मैं साइडकीक-प्रो की बैचिंग कार्यक्षमता के समान कॉलबैक निष्पादित करने से पहले सभी श्रमिकों को पूरा करने के लिए इंतजार करने का सबसे अच्छा तरीका सलाह ढूंढ रहा हूं। संभावित विकल्पों पर कोई सलाह बहुत सराहना की जाएगी!

Answer 1

सरल उपयोग के मामलों के लिए आप प्रत्येक कतार के लिए लंबित नौकरियों की गिनती के लिए stats पर मतदान कर सकते हैं।

तो यदि आप जानते हैं कि आपकी सभी नौकरियां एक विशिष्ट कतार में जाती हैं, और अन्य जगहों से उस कतार में कोई और नौकरियां नहीं जा रही हैं तो यह पर्याप्त होगा। और अधिक उन्नत/जटिल उपयोग के मामलों के लिए आप एक घटना API source

एक और सरल समाधान एक Redis आधारित काउंटर (के बाद से आप पहले से ही Redis उपयोग कर रहे हैं) हर काम से उपयोग करें और यह atomically decrement है, और publish उल्लेख कर सकते हैं एक बार गिनती शून्य तक पहुंच ।

Answer 2

आप एक विधि लिख सकते हैं:

def wait_for_sidekiq 
    sleep(1) until Sidekiq::Workers.new.size == 0 && Sidekiq::Queue.new.size == 0 
end 

मैंने देखा कि आपने यह सुनिश्चित करें कि नौकरियों पहली जगह में पंक्तिबद्ध हो गया बनाने के सुझाव है:

def wait_for_queuing 
    sleep(1) until Sidekiq::Queue.new.size > 0 || Sidekiq::Workers.new.size > 0 
end 

यह आवश्यक है, क्योंकि कभी-कभी पहले नौकरियों को छोड़ने से पहले विधि को कुछ मिलीसेकंड निष्पादित किया जा सकता है, ताकि वह बिल्कुल इंतजार न करे।

Answer 3

आप इस Sidekiq-batch gem देखना चाहिए, मैं पहले से ही यह कोशिश करते हैं और यह सिर्फ तरह Sidekiq के प्रो बैच काम करता है, और यह मुक्त

आशा है यह मदद कर सकता है