I Webjobs rinnovano automaticamente i lease sui messaggi di Azure Queue?

Question

Quando Webjob riceve un messaggio da una coda su Archiviazione di Azure tramite QueueTrigger, affitta il messaggio (lo rende invisibile). Se la funzione di attivazione (di webjob) impiega molto tempo per elaborare il messaggio, questo lease viene automaticamente esteso? O dovrei gestirlo nella funzione?

Su questo link Windows Azure Queues: Improved Leases, Progress Tracking, and Scheduling of Future Work, l'autore afferma che "un contratto di locazione il messaggio può essere esteso dal lavoratore che ha fatto il dequeue originale in modo che possa continuare l'elaborazione del messaggio"

Nota: ho provato un webjob (con un QueueTrigger) che aspetta 20 minuti.

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

È stato completato correttamente. E durante questo periodo nessuna altra istanza di webjob tenta di tentare lo stesso oggetto della coda (non è diventato visibile). Pertanto sembra che esista un meccanismo di rinnovo automatico per locazioni. Comunque sto aspettando una risposta da un dipendente Microsoft o con un link ufficiale (msdn, azzurro, ...).

Answer 1

Sì, il leasing viene automaticamente esteso. Sono 10 minuti ogni volta.

Vedere questa risposta qui [1] da un dipendente Microsoft che fa riferimento ai documenti e ai commenti su azure.microsoft.com [2].

EDIT (risposta lunga)

Inoltre, l'esame del codice sorgente, iniziando con la classe QueueListener al https://github.com/Azure/azure-webjobs-sdk/blob/cfc875a7f00e595410c0603e6ca65537025490a9/src/Microsoft.Azure.WebJobs.Host/Queues/Listeners/QueueListener.cs indica stessa.

Il codice QueueListener ha i componenti sulla linea 138, in cui viene definita la visibilityTimeout variabile 10 minuti:

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

Tale variabile viene quindi trasmesso al ProcessMessageAsync, che avvia un timer definito nel metodo CreateUpdateMessageVisibilityTimer con quello stesso valore. Il valore di 10 minuti viene utilizzato per determinare quando il primo e il successivo aggiornano anche il timeout di visibilità (dimezzandolo e creando un'istanza della classe LinearSpeedupStrategy).

Alla fine, nella classe UpdateQueueMessageVisibilityCommand [3], si scoprirà che il metodo UpdateMessageAsync in coda viene chiamato con lo stesso rinnovo di 10 minuti.

Il LinearSpeedupStrategy si rinnoverà di nuovo dopo 5 minuti, a meno che il rinnovo non sia andato a buon fine, nel qual caso riproverà dopo 1 minuto (come definito in 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

È possibile utilizzare il metodo (codice Java):

queue.retrieveMessage() 

per ottenere un messaggio da una coda per il magazzinaggio azzurro. Sarà visibile dopo 30 secondi per impostazione predefinita.

Se si desidera estendere il contratto di locazione, è possibile utilizzare il codice qui sotto:

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

Questo significa che il messaggio sarà in grado di essere trattati per altri 60 secondi.