J'utilise une file d'attente de tâches Celery pour traiter les requêtes Web de manière asynchrone. Si je voulais empêcher les travailleurs de traiter le même type de tâche trop souvent, est-il possible pour un travailleur de remettre une tâche en attente? Il est certainement possible d'avoir un travailleur qui dort sur une tâche, mais je ne veux pas attacher les travailleurs qui dorment sur des tâches. Des pensées?Puis-je avoir une tâche Celery reenqueue?
1
A
Répondre
1
Ma réponse est presque certainement dans les options ETA/Compte à rebours: http://docs.celeryproject.org/en/master/userguide/calling.html#eta-and-countdown How can I defer the execution of Celery tasks?
Je ne l'avais pas envisagé de mettre la logique d'attente du côté tâche générateur. Je vais jouer avec ça un peu.
Questions connexes
- 1. Comment retarder une tâche avec Celery?
- 2. Celery crée plusieurs instances de tâche
- 3. Importation dynamique d'un module dans une tâche Celery
- 4. Dans Celery, comment exécuter une tâche, puis exécuter une autre tâche et la maintenir?
- 5. Annulation d'une tâche en cours dans Celery dans django
- 6. Connexion et enregistrement de données avec Redis Inside Celery Tâche
- 7. Celery - collision de task_ids
- 8. Arguments d'accès à la tâche parent de la sous-tâche dans Celery
- 9. Django Celery Workflow Pause/Resume
- 10. Celery + RabbitMQ Résultats Backend + WebSockets?
- 11. Django Celery Erreur
- 12. L'utilisation de transactions dans une tâche Celery dans l'application Django peut-elle causer des problèmes?
- 13. La bonne façon d'exécuter une tâche de manière asynchrone dans Django, via Celery
- 14. Comment planifier une tâche avec Celery qui s'exécute le 1er de chaque mois?
- 15. Celery Instanciation cache
- 16. Importer des modèles tâches celery
- 17. Statut des tâches Python Celery
- 18. Modification dynamique des paramètres Celery Beat
- 19. Strange Docker + Celery Bug
- 20. L'instruction d'impression dans la tâche planifiée Celery n'apparaît pas dans le terminal
- 21. Comment appeler une procédure après avoir terminé la tâche
- 22. File d'attente simple avec Celery et RabbitMQ
- 23. Inverser les urls dans Django/Celery
- 24. Celery/Kombu ignorant run_every
- 25. Celery ne libère pas de mémoire
- 26. Django Celery erreur d'installation
- 27. Celery django explication
- 28. Django Celery définit un chemin de fichier journal individuel pour chaque tâche
- 29. Comment puis-je m'assurer qu'une tâche Celery s'exécute avec les bons paramètres?
- 30. Une tâche de rythme de céleri finie