file d'attente simple avec Céleri et RabbitMQ

Question

Je suis en train de mettre en œuvre une file d'attente simple qui exécute une tâche à la fois. tâches déchargeant hors le thread principal à l'aide Céleri et réglage = 1 dans concurrency la config Céleri fonctionne très bien, mais je pourrais vouloir utiliser davantage de travailleurs simultanés pour d'autres tâches.

Est-il possible de dire Céleri ou RabbitMQ de ne pas utiliser plusieurs travailleurs simultanés pour une tâche (sauf en forçant = 1 concurrency)? Je ne peux pas trouver quoi que ce soit dans la documentation, mais peut-être ces outils ne sont pas conçus pour une file d'attente linéaire?

Merci!

Answer 1

Je pense que ce que vous avez besoin est une file d'attente distincte pour chaque type de tâche. Créer des travailleurs distincts qui consomment de chaque file d'attente, avec jeu de simultanéité à 1.