Czy Webjobs automatycznie odnawia dzierżawy w wiadomościach kolejki Azure?

Question

Gdy Webjobs pobiera wiadomość z kolejki w magazynie Azure za pośrednictwem QueueTrigger, dzierżawi wiadomość (czyni ją niewidoczną). Jeśli funkcja wyzwalania (webjob) zajmuje dużo czasu na przetworzenie wiadomości, czy to dzierżawa jest automatycznie przedłużana? Czy powinienem sobie z tym poradzić w funkcji?

na ten link Windows Azure Queues: Improved Leases, Progress Tracking, and Scheduling of Future Work, autor stwierdza, że ​​„Leasing na komunikat może zostać przedłużony przez pracownika, który zrobił oryginalną rozkolejkowania tak, że może kontynuować przetwarzania komunikatu”

Uwaga: mam próbował webjob (z QueueTrigger), który czeka 20 minut.

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

Pomyślnie zakończono. I w tym czasie żadna inna instancja webjob nie próbuje wykonać tego samego elementu kolejki (nie stała się widoczna). Dlatego wydaje się, że istnieje mechanizm automatycznego odnawiania dzierżaw. W każdym razie czekam na odpowiedź od pracownika firmy Microsoft lub z oficjalnym linkiem (msdn, azure, ...).

Answer 1

Tak, dzierżawa jest automatycznie przedłużana. Za każdym razem jest to 10 minut.

Zobacz tę odpowiedź tutaj [1] przez pracownika firmy Microsoft, odnosząc się do dokumentów i komentarzy na temat azure.microsoft.com [2].

EDIT (długie odpowiedzi)

Ponadto, badanie kodu źródłowego, wychodząc z klasy QueueListener w https://github.com/Azure/azure-webjobs-sdk/blob/cfc875a7f00e595410c0603e6ca65537025490a9/src/Microsoft.Azure.WebJobs.Host/Queues/Listeners/QueueListener.cs oznacza takie same.

Kod w QueueListener ma odpowiednie części na linii 138, w którym 10 minut visibilityTimeout zmiennej Definicja:

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

Zmienna jest następnie przekazane do ProcessMessageAsync, który uruchamia stoper zdefiniowane w metodzie CreateUpdateMessageVisibilityTimer z tą samą wartością. Wartość 10-minutowa służy do określenia, kiedy pierwsza i następna aktualizacja limitu czasu widoczności również (poprzez zmniejszenie o połowę wartości i utworzenie instancji klasy LinearSpeedupStrategy).

Ostatecznie, w klasie UpdateQueueMessageVisibilityCommand [3], okaże się, że metoda UpdateMessageAsync w kolejce jest wywoływana z tym samym 10-minutowym odnawianiem.

Ponownie zostanie odnowiona po 5 minutach, chyba że odnowienie się nie powiodło, w takim przypadku spróbuje ponownie po upływie 1 minuty (jak zdefiniowano w 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

Można użyć metody (kod Java):

queue.retrieveMessage() 

aby otrzymać wiadomość z kolejki na lazurowym przechowywania. Będzie domyślnie widoczny po 30 sekundach.

Jeśli chcą przedłużenia dzierżawy, można użyć kodu poniżej:

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

Oznacza to wiadomość będzie mógł być przetwarzane przez kolejne 60 sekund.