celery

30Nhiệt

2Trả lời

Đặt giới hạn thời gian cho một nhiệm vụ cụ thể với cần tây

Tôi có một nhiệm vụ trong Celery có khả năng chạy trong 10.000 giây trong khi hoạt động bình thường. Tuy nhiên, tất cả các nhiệm vụ còn lại của tôi sẽ được thực hiện trong chưa đầy một giây. Làm thế n

6Nhiệt

1Trả lời

Số lượng quy trình celeryd có phụ thuộc vào cài đặt --concurrency không?

Chúng tôi đang chạy cần tây đằng sau Supervisor và bắt đầu nó với celeryd --events --loglevel=INFO --concurrency=2 này, tuy nhiên, tạo ra một biểu đồ quá trình đó là lên đến ba lớp sâu và chứa lên đ

8Nhiệt

1Trả lời

nhân cần tây không thử lại nhiệm vụ sau khi gọi retry()

Tôi có một nhiệm vụ: @celery.task(name='request_task',default_retry_delay=2,acks_late=True) def request_task(data): try: if some_condition: request_task.retry() except

6Nhiệt

1Trả lời

Tự động thay đổi cài đặt Beat Celery

Có cách nào để cho biết cần thiết thay đổi cài đặt cho một tác vụ cụ thể trong khi đang chạy không? Tiện ích này được minh họa tốt nhất trong ví dụ này: Tôi có nhiệm vụ định kỳ kiểm tra giá trị sau mỗ

5Nhiệt

1Trả lời

Kết hợp kết quả công việc trong cần tây

Tôi đang làm việc trên một hệ thống nâng cấp phần mềm sử dụng cần tây. Tôi có một trường hợp sử dụng mà tôi đang đấu tranh để thực hiện sạch sẽ. Dưới đây là công việc của tôi: device_software_updates

6Nhiệt

1Trả lời

nhận phân phối lỗiNotFound

Tôi đã cài đặt celeryD và redis trên hệ thống của mình. khi tôi đang chạy lệnh sử dụng celery. Tôi nhận được lỗi sau. Traceback (most recent call last): File "/usr/local/bin/celeryd", line 5, in

10Nhiệt

2Trả lời

nhận được lỗi nhận nhiệm vụ đăng ký kiểu 'mytasks.add'

Tôi đã viết một tập tin mytasks.py from celery import Celery celery = Celery("tasks", broker='redis://localhost:6379/0', backend='redis') @celery.task def add(x,y): return

5Nhiệt

2Trả lời

Lập kế hoạch hàng ngàn nhiệm vụ một lần (không tái) để thực hiện gần như đồng thời qua Django-celery

Một số ngữ cảnh: Tôi đang xây dựng một Ứng dụng Django cho phép người dùng lưu trước một hành động và lên lịch chính xác/thời gian trong tương lai họ muốn nói hành động để thực hiện. Ví dụ: lên lịch c

6Nhiệt

1Trả lời

Lỗi khung trong Celery 3.0.1

Gần đây tôi đã nâng cấp lên Celery 3.0.1 từ 2.3.0 và tất cả các tác vụ đều chạy tốt. Không may. Tôi nhận được một ngoại lệ "Lỗi khung" khá thường xuyên. Tôi cũng đang chạy giám sát để khởi động lại cá

5Nhiệt

1Trả lời

Tôi muốn sử dụng gevent.evnet vào celery.task

Tôi đã làm việc trên hệ thống bỏ phiếu dài. tôi dùng bình + mongokit + cần tây + gevent. Khi quá trình trong nhiệm vụ cần tây, được thực hiện gevent.event.set() công việc không thực hiện. vì vậy tôi m