Imposta nextVisibleTime nell'SDK Webjobs di Azure

Question

Sto usando i Webjobs di Azure per elaborare i messaggi da una coda.

Ho visto che l'SDK di Webjobs elabora nuovamente un messaggio non riuscito dopo 10 minuti e, se fallisce 5 volte, lo sposta nella coda velenosa (1).

Inoltre, è possibile vedere il prossimo Tempo disponibile del messaggio nella coda, ovvero 10 minuti dopo l'intervallo di inserimento (2).

Desidero utilizzare la gestione degli errori dei messaggi di AzureSDK ma non riesco ad attendere 10 minuti affinché il messaggio venga elaborato nuovamente.

C'è un modo per impostare questo prossimo Tempo Visibile su alcuni secondi?

Create a .NET WebJob in Azure App Service

Se il metodo non riesce prima di completare, il messaggio della coda non viene eliminato; dopo un lease di 10 minuti scade, il messaggio viene rilasciato per essere raccolto nuovamente ed elaborato.

How to use Azure queue storage with the WebJobs SDK

public static void WriteLog([QueueTrigger("logqueue")] string logMessage, 
    DateTimeOffset expirationTime, 
    DateTimeOffset insertionTime, 
    DateTimeOffset nextVisibleTime, 

Nota: Non ci sono domande simili qui in StackOverflow ma senza risposta:

• QueueTrigger Attribute Visibility Timeout
• Azure WebJob QueueTrigger Retry Policy

Answer 1

Se c'è un'eccezione durante l'elaborazione della tua funzione, l'SDK riporterà immediatamente il messaggio in coda e il messaggio verrà rielaborato. Non vedi questo comportamento?

Answer 2

In ultima release v1.1.0, è ora possibile controllare il timeout visibilità registrando le tue QueueProcessor casi tramite JobHostConfiguration.Queues.QueueProcessorFactory. Ciò consente di controllare il comportamento avanzato di elaborazione dei messaggi a livello globale o per coda/funzione.

Ad esempio, per impostare la visibilità per i messaggi non riusciti, è possibile ignorare ReleaseMessageAsync come segue:

protected override async Task ReleaseMessageAsync(CloudQueueMessage message, FunctionResult result, TimeSpan visibilityTimeout, CancellationToken cancellationToken) 
{ 
    // demonstrates how visibility timeout for failed messages can be customized 
    // the logic here could implement exponential backoff, etc. 
    visibilityTimeout = TimeSpan.FromSeconds(message.DequeueCount); 

    await base.ReleaseMessageAsync(message, result, visibilityTimeout, cancellationToken); 
} 

Maggiori dettagli possono essere trovati nel release notes here.