tâches Céleri nouvelle tentative (Céleri, Django et RabbitMQ)

Question

Pouvez-vous me dire ce qui se passe quand le céleri vous dire la tâche de nouvelle tentative? Est-il une nouvelle tentative dans le même thread de travail ou il sera retourné au courtier qui peut l'envoyer ailleurs?

Qu'est-ce qui va se passer avec les tâches pour nouvelle tentative si le travailleur ou expéditeur soudainement arrêter? Si les tâches peuvent être perdues est-il une approche pour éviter cela? Peut-être sauver chaque tâche dans la base de données et de les recommencer si aucun résultat reçu pendant un certain temps?

Ou peut-être avoir dispatcher son propre stockage persistant? Qu'en est-il alors si l'accident de thread de travail recevant la tâche ou en exécuter?

Answer 1

Pouvez-vous me dire ce qui se passe quand dans le céleri vous dire la tâche à une nouvelle tentative? Est-il une nouvelle tentative dans le même travailleur fil ou il sera retourné à courtier qui peut l'envoyer ailleurs?

Oui, le retour de la tâche au courtier (ex. Lapin MQ) avec un temps d'exécution estimé différente

Qu'est-ce qui va se passer avec les tâches pour retry si le travailleur ou expéditeur soudainement arrêter? Si les tâches peuvent être perdues est-il un approche pour éviter cela? Peut-être sauver chaque tâche dans la base de données et les retenter si aucun résultat est reçu pour certains temps? Ou peut-être dispatcher avoir son propre stockage persistant? Qu'en est-il alors si accident de thread de travail recevant la tâche ou en exécuter?

Voici une réponse complète Retry perdu ou tâches ayant échoué (Céleri , Django et RabbitMQ)