Le worker ne consomme pas de tâches après l'appel de céleri add_consumer

Question

J'aimerais utiliser Celery (avec RabbitMQ comme backend MQ) pour exécuter des tâches de différentes saveurs via différentes files d'attente. Une exigence est que la consommation (par les travailleurs) d'une file d'attente particulière devrait avoir la capacité d'être mise en pause et de reprendre. Céleri, semble avoir this capability en appelant add_consumer et cancel_consumer. Tandis que j'étais capable d'annuler la consommation de tâches d'une file d'attente pour un travailleur particulier, je ne peux pas obtenir le travailleur de reprendre la consommation en appelant add_consumer. The code to reproduce this issue is provided here. Ma conjecture est probable que je manque une sorte de paramètre à fournir soit dans le celeryconfig ou via les arguments lors du démarrage des travailleurs?

Serait génial d'avoir quelques nouvelles paires d'yeux sur ce sujet. Il n'y a pas beaucoup de discussion sur Stackoverflow concernant add_consumer ni dans Github. J'espère donc que certains experts sont prêts à partager leurs pensées et expériences.

-

Je courais le ci-dessous:

OS Windows, RabbitMQ 3.5.6, Erlang 18.1, Python 3.3.5, le céleri 3.1.15

Answer 1

Pour reprendre la file d'attente, vous besoin de spécifier le nom de la file d'attente ainsi que les travailleurs cibles. Voici comment faire.

app.control.add_consumer(queue='high', destination=['celery@asus']) 

est ici add_consumer signature

def add_consumer(state, queue, exchange=None, exchange_type=None, 
      routing_key=None, **options): 

Dans votre cas, vous appelez avec

app.control.add_consumer('high', destination=['celery@high1woka']) 

Alors high devient passé à l'autre et la file d'attente est vide. Donc, il n'est pas capable de reprendre.