Kerter'de django içinde çalışan bir görevi durdurma

Question

Bir Kereviz kuyruğundan (rabbitMQ kullanarak) çalışan bir görevi iptal edebilmek istiyorum. AsyncBoot tanımlı bir görev olan

'u kullanarak görevi arıyorum.

Görev kimliğini (bu apply_async döndüren uzun dize olduğunu varsayarak) alabilir ve veritabanında saklayabilirim ancak iptal yöntemini nasıl arayacağımı bilmiyorum. Abortable görevler sınıfı ile nasıl abortable yöntemlerin nasıl yapıldığını görüyorum, ancak yalnızca task-id dizesine sahip olsaydım, görevde .abort() öğesini nasıl ararım? Teşekkürler.

Answer 1

apply_async bir AsyncResult örneğini verir veya bu durumda bir AbortableAsyncResult içinde: http://celeryq.org/docs/reference/celery.contrib.abortable.html

görev kullanımını result.abort() durdurmak için. task_id'u kaydedin ve modelini yeni bir örnek oluşturmak için kullanın ve default_backend'u kullanmıyorsanız arka uç isteğe bağlı bağımsız değişken sağladığınızdan emin olun.

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

Sonra:

abortable_async_result = AbortableAsyncResult(myTaskId) 
abortable_async_result.abort() 

Answer 2

Referans belgelerini gördünüz mü?

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