Hủy bỏ tác vụ đang chạy trong Celery trong django

Question

Tôi muốn có thể hủy bỏ một tác vụ đang chạy từ hàng đợi Celery (sử dụng rabbitMQ). Tôi gọi công việc bằng cách sử dụng

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

nơi AsyncBoot là một tác vụ được xác định.

Tôi có thể nhận được ID nhiệm vụ (giả sử đó là chuỗi dài apply_async trả về) và lưu trữ nó trong cơ sở dữ liệu nhưng tôi không biết cách gọi phương thức hủy. Tôi thấy làm thế nào để làm cho phương pháp abortable với lớp nhiệm vụ Abortable nhưng nếu tôi chỉ có chuỗi nhiệm vụ id, làm thế nào để tôi gọi .abort() trên công việc? Cảm ơn.

Answer 1

apply_async trả về một thể hiện AsyncResult, hoặc trong trường hợp này một AbortableAsyncResult. Lưu task_id và sử dụng điều đó để tạo nhanh AbortableAsyncResult sau này, đảm bảo bạn cung cấp đối số tùy chọn phụ trợ nếu bạn không sử dụng default_backend.

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

Sau đó:

abortable_async_result = AbortableAsyncResult(myTaskId) 
abortable_async_result.abort() 

Answer 2

Bạn có thấy tài liệu tham chiếu không? http://celeryq.org/docs/reference/celery.contrib.abortable.html

Để hủy bỏ việc sử dụng nhiệm vụ result.abort():

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