Interrompere un'attività in esecuzione in Celery all'interno di django

Question

Vorrei poter interrompere un'attività in esecuzione da una coda di Celery (utilizzando rabbitMQ). Chiamare l'attività utilizzando

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

dove AsyncBoot è un'attività definita.

È possibile ottenere l'ID dell'attività (supponendo che sia la stringa lunga che restituisce apply_async) e memorizzarlo in un database, ma non sono sicuro su come chiamare un metodo di interruzione. Vedo come rendere i metodi più comodi con la classe di attività Abortable, ma se ho solo la stringa id-task, come posso chiamare .abort() sull'attività? Grazie.

Answer 1

apply_async restituisce un'istanza AsyncResult, o in questo caso un AbortableAsyncResult. Salvare lo task_id e utilizzarlo per creare un'istanza di un nuovo AbortableAsyncResult in seguito, assicurandosi di fornire l'argomento facoltativo di back-end se non si sta utilizzando lo default_backend.

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

tardi:

abortable_async_result = AbortableAsyncResult(myTaskId) 
abortable_async_result.abort() 

Answer 2

Hai visto la documentazione di riferimento? http://celeryq.org/docs/reference/celery.contrib.abortable.html

Per interrompere l'utilizzo compito result.abort():

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