Có cách nào để ngăn chặn phi công việc đặc biệt của công nhân cần tây không?

Question

Vì trạng thái Celery documentation, tác vụ đã thực hiện sẽ không bị hủy bỏ bằng cách gọi .revoke(), trừ khi terminate=True được đặt. Nhưng điều đó không được khuyến khích, bởi vì nó sẽ tự giết chính nhân viên, điều này có thể đã bắt đầu một nhiệm vụ khác. Điều đó có nghĩa là không có cách nào đáng tin cậy, ổn định để làm điều đó?

EDIT: celery.contrib.abortable không phù hợp với tôi, bởi vì, như trạng thái tài liệu, nó chỉ hoạt động với các phần phụ trợ cơ sở dữ liệu.

Answer 1

Tác vụ đang chạy là tiến trình con đang chạy của nhân viên (khi sử dụng prefork), điều này có nghĩa là cách duy nhất để hủy bỏ một nhiệm vụ là tiêu diệt tiến trình con đang chạy nó.

Bạn có thể thử thực hiện việc xử lý sự kiện thu hồi của riêng mình để tìm ra ID tiến trình con và chỉ xóa ID đó, nhưng thành thật không biết liệu có đáng giá hay không và liệu nó có thực sự hoạt động hay không.

Tôi nghĩ câu trả lời ngắn gọn là bạn không thể.

Dù sao giết người lao động là cần thiết đôi khi, đặc biệt là trong giai đoạn đầu của dự án mà bạn vẫn cần phải kích thước một cách chính xác các nguồn lực, chỉ cần đảm bảo bạn đăng nhập ở đâu đó những nhiệm vụ đang chạy, do đó bạn có thể sắp xếp lại chúng hoặc chỉ sử dụng CELERY_ACKS_LATE

Answer 2

Bạn có thể gửi tín hiệu HUP thay vì TERM để khởi động lại quy trình con một cách duyên dáng mà không giết người lao động.

In [80]: import signal 

In [81]: x = add.delay(1, 2) 

In [82]: x.revoke(terminate=True, signal=signal.SIGHUP)