comment faire pour supprimer la tâche de céleri avec redis courtier?

J'Ai ajouter un peu de mal task à un celery avec redis broker

mais maintenant, je veux supprimer la mauvaise task et je ne trouve pas de façon de le faire

Est qu'il y a certaines commandes ou de certaines api pour ce faire ?

Voir si ça va aider: stackoverflow.com/questions/2557424/...

OriginalL'auteur timger | 2013-06-19

  1. 22

    J'en connais deux façons de le faire:

    1) Supprimer de la file d'attente directement à partir de courtier. Dans votre cas, c'est le Redis. Il y a deux commandes qui pourrait vous aider: llen (trouver la bonne file d'attente) et del (à supprimer).

    2) Démarrer le céleri travailleur avec --purge ou --jeter options. Voici de l'aide:

    --purge, --discard    Purges all waiting tasks before the daemon is started.
                      **WARNING**: This is unrecoverable, and the tasks will
                      be deleted from the messaging server.
    merci pour la relecture, le céleri est trop complexe,j'ai modifier mon projet de python-rq
    Il ne fonctionne pas pour moi. Reddis a encore toute la file d'attente et je ne peux pas le supprimer. Le céleri continue de recevoir des tâches
    Dans le cas où ce n'est pas de nettoyer l'ensemble de votre céleri questions, je vous encourage à vérifier pour zombie processus à l'aide de ps et exécuter kill sur eux.

    OriginalL'auteur Artem Mezhenin

  2. 2

    Je viens d'avoir ce problème donc pour les futurs lecteurs,

    http://celery.readthedocs.org/en/latest/faq.html#i-ve-purged-messages-but-there-are-still-messages-left-in-the-queue

    afin de purger correctement la file d'attente de tâches que vous avez à arrêter tous les
    les travailleurs    , puis purger les tâches à l'aide de céleri.de contrôle.purger().

    OriginalL'auteur straykiwi

  3. 1

    1.
    Pour bien purger la file d'attente des tâches en attente, vous devez arrêter tous les travailleurs (http://celery.readthedocs.io/en/latest/faq.html#i-ve-purged-messages-but-there-are-still-messages-left-in-the-queue):

    2 ... et puis purger les tâches à partir d'une file d'attente spécifique:

    $ cd <source_dir
$ celery amqp queue.purge <queue name>

    3.
    Début des travailleurs de nouveau

    OriginalL'auteur Ukr