CloudQueueMessage - mécanisme de réessai

Question

J'utilise Azure Storage Queues pour gérer le flux de traitement de mes éléments. Tâches entrent dans la file d'attente, En cours de traitement par le serveur d'arrière-plan et retiré de la file d'attente.

Dans certains cas, le traitement d'une tâche échoue (en raison de variables d'environnement inattendues). Dans ce cas, je souhaite réessayer l'exécution de la tâche. Si cette fois le traitement s'est bien passé, tout est bon - il suffit de le retirer de la file d'attente. Sinon, retirez-le de la file d'attente et écrivez un message dans le journal. Donc, je cherche un mécanisme pour ajouter des méta-données à l'élément CloudQueueMessage. Je pense à une nouvelle méta-donnée appelée "retries". Ce qui sera un compteur. Mais je ne vois aucune option pour ajouter des méta-données à un élément de file d'attente.

Une autre option consiste à envelopper mon élément avec la classe Wrapper qui ajoutera la propriété 'retries'. Après avoir mis en file d'attente l'élément de la file d'attente, réinsérez-le avec la valeur 'retries' modifiée. Cela devrait fonctionner mais pas une solution élégante.

Quelles sont vos recommandations?

Answer 1

Vous ne devez pas. Lorsque l'élément a été récupéré par votre rôle de travail dans la file d'attente, il est toujours présent mais marqué comme non visible. Par défaut, il est invisible pendant 30 secondes. Vous pouvez cependant définir la visibilité en utilisant "visibilityTimeout". L'élément reste dans la file d'attente jusqu'à ce que vous l'enleviez.