क्या वेबजोज़ स्वचालित रूप से Azure Queue संदेशों पर पट्टे को नवीनीकृत करते हैं?

Question

जब वेबबॉज को क्यूयू ट्रिगर के माध्यम से एज़ूर स्टोरेज पर कतार से संदेश मिलता है, तो यह संदेश पट्टे पर देता है (इसे अदृश्य बनाता है)। यदि ट्रिगरिंग फ़ंक्शन (वेबोज़ का) संदेश को संसाधित करने में लंबा समय लगता है, तो क्या यह पट्टा स्वचालित रूप से बढ़ाया जाता है? या मैं इसे समारोह में संभाल लेना चाहिए?

इस लिंक Windows Azure Queues: Improved Leases, Progress Tracking, and Scheduling of Future Work पर, लेखक कहता है कि "संदेश पर एक पट्टा कार्यकर्ता है कि मूल विपंक्ति किया द्वारा बढ़ाया जा सकता है ताकि यह संदेश प्रोसेस जारी रख सकते हैं"

नोट: मैंने एक वेबबॉज (एक QueueTrigger के साथ) की कोशिश की जो 20 मिनट के लिए इंतजार कर रहा है।

//Write Log 
Thread.Sleep(1200000); 
//Write Log 

यह सफलतापूर्वक पूरा हो गया है। और इस समय के दौरान कोई अन्य वेबबॉज उदाहरण एक ही कतार आइटम (यह दिखाई नहीं दे रहा था) के लिए प्रयास करने का प्रयास करें। इसलिए ऐसा लगता है कि पट्टे के लिए एक ऑटो-नवीनीकरण तंत्र मौजूद है। किसी भी तरह से मैं एक Microsoft कर्मचारी या एक आधिकारिक लिंक (एमएसडीएन, एज़ूर, ...) के साथ एक जवाब का इंतजार कर रहा हूँ।

Answer 1

हां, आपका पट्टा स्वचालित रूप से बढ़ाया गया है। यह हर बार 10 मिनट है।

यह उत्तर यहां देखें [1] एक Microsoft कर्मचारी द्वारा dzure.microsoft.com [2] पर दस्तावेज़ों और टिप्पणियों का जिक्र करते हुए।

संपादित (विस्तृत उत्तर)

इसके अलावा, स्रोत कोड की जांच, https://github.com/Azure/azure-webjobs-sdk/blob/cfc875a7f00e595410c0603e6ca65537025490a9/src/Microsoft.Azure.WebJobs.Host/Queues/Listeners/QueueListener.cs पर QueueListener वर्ग के साथ शुरू ही इंगित करता है।

QueueListener में कोड लाइन 138, जहां 10 मिनट visibilityTimeout चर परिभाषित किया गया है पर प्रासंगिक भाग हैं:

TimeSpan visibilityTimeout = TimeSpan.FromMinutes(10); // long enough to process the job 

चर तो ProcessMessageAsync है, जो एक टाइमर विधि CreateUpdateMessageVisibilityTimer में परिभाषित शुरू होता है को भेज दिया जाता है यही कारण है कि उसी मूल्य के साथ। 10 मिनट का मान यह निर्धारित करने के लिए किया जाता है कि दृश्यता समय समाप्ति के पहले और अगले अपडेट (इसे रोककर और LinearSpeedupStrategy कक्षा का उदाहरण बनाकर)।

आखिरकार, कक्षा UpdateQueueMessageVisibilityCommand [3] में, आप पाएंगे कि UpdateMessageAsync कतार पर विधि को उसी 10 मिनट के नवीकरण के साथ बुलाया जाता है।

LinearSpeedupStrategy 5 मिनट के बाद फिर से नवीनीकृत होगा, जब तक कि नवीनीकरण विफल नहीं हो जाता है, तब तक यह 1 मिनट के बाद फिर से प्रयास करेगा (जैसा कि QueueListener में परिभाषित किया गया है)।

[1] Azure Storage Queue and multiple WebJobs instances: will QueueTrigger set the message lease time on triggered?

[2] https://azure.microsoft.com/en-us/documentation/articles/websites-dotnet-webjobs-sdk-get-started/

[3] https://github.com/Azure/azure-webjobs-sdk/blob/cfc875a7f00e595410c0603e6ca65537025490a9/src/Microsoft.Azure.WebJobs.Host/Queues/Listeners/UpdateQueueMessageVisibilityCommand.cs

Answer 2

आप विधि (जावा कोड) का उपयोग कर सकते हैं:

queue.retrieveMessage() 

नीला भंडारण पर एक कतार से एक संदेश प्राप्त करने के लिए। यह डिफ़ॉल्ट रूप से 30 सेकंड के बाद दिखाई देगा।

आप पट्टे का विस्तार करना चाहते हैं, तो आप नीचे दिए गए कोड का उपयोग कर सकते हैं:

CloudQueueMessage updateMessage = queue.retrieveMessage(); 
EnumSet<MessageUpdateFields> updateFields = EnumSet.of(MessageUpdateFields.CONTENT, MessageUpdateFields.VISIBILITY); 
queue.updateMessage(updateMessage, 60, updateFields, null, null); 

इसका मतलब यह है अपने संदेश एक और 60 सेकंड के लिए संसाधित करने के लिए सक्षम हो जाएगा।