Annulation d'une tâche en cours dans Celery dans django

Question

Je voudrais être en mesure d'interrompre une tâche qui s'exécute à partir d'une file d'attente Celery (en utilisant rabbitMQ). J'appelle la tâche en utilisant

task_id = AsyncBoot.apply_async(args=[name], name=name, connect_timeout=3) 

où AsyncBoot est une tâche définie.

Je peux obtenir l'ID de la tâche (en supposant que c'est la chaîne longue que renvoie apply_async) et le stocker dans une base de données, mais je ne sais pas comment appeler une méthode d'abandon. Je vois comment faire des méthodes avortables avec la classe des tâches Abortable mais si je n'ai que la chaîne task-id, comment puis-je appeler .abort() sur la tâche? Merci.

Answer 1

apply_async retourne une instance AsyncResult, ou dans ce cas un AbortableAsyncResult. Enregistrez le task_id et utilisez-le pour instancier un nouveau AbortableAsyncResult ultérieurement, en vous assurant de fournir l'argument facultatif backend si vous n'utilisez pas le default_backend.

abortable_async_result = AsyncBoot.apply_async(args=[name], name=name, connect_timeout=3) 
myTaskId = abortable_async_result.task_id 

plus tard:

abortable_async_result = AbortableAsyncResult(myTaskId) 
abortable_async_result.abort() 

Answer 2

Avez-vous vu la documentation de référence? http://celeryq.org/docs/reference/celery.contrib.abortable.html

Pour interrompre l'utilisation de la tâche result.abort():

>>> result = AsyncBoot.apply_async(...) 
>>> result.abort()