Ví dụ về Django và Celery: Nhiệm vụ định kỳ

Question

Tôi đã chiến đấu với tài liệu Django/Celery trong một thời gian và cần trợ giúp.

Tôi muốn có thể chạy Công việc định kỳ bằng django-cần tây. Tôi đã thấy trên internet (và tài liệu hướng dẫn) một số định dạng và lược đồ khác nhau về cách thức người ta nên đi về việc đạt được điều này bằng cách sử dụng Celery ...

Ai đó có thể giúp với một ví dụ cơ bản, hoạt động của việc tạo, đăng ký và thực hiện một nhiệm vụ định kỳ django-cần tây? Đặc biệt, tôi muốn biết liệu tôi có nên viết một nhiệm vụ mở rộng lớp PeriodicTask và đăng ký hay không, hoặc liệu tôi có nên sử dụng trang trí @periodic_task hay không hoặc liệu tôi có nên sử dụng trình trang trí @task hay không và sau đó thiết lập lịch biểu cho tác vụ chấp hành.

Tôi không quan tâm nếu cả ba cách đều có thể, nhưng tôi muốn xem ví dụ về ít nhất một cách hoạt động. Rất biết ơn sự giúp đỡ của bạn.

Answer 1

Có gì sai với example from the docs?

from celery.task import PeriodicTask 
from clickmuncher.messaging import process_clicks 
from datetime import timedelta 


class ProcessClicksTask(PeriodicTask): 
    run_every = timedelta(minutes=30) 

    def run(self, **kwargs): 
     process_clicks() 

Bạn có thể viết các nhiệm vụ tương tự sử dụng một trang trí:

from celery.task.schedules import crontab 
from celery.task import periodic_task 

@periodic_task(run_every=crontab(minute="*/30")) 
def process_clicks(): 
    .... 

Các decorator syntax đơn giản cho phép bạn bật chức năng hiện có/nhiệm vụ vào một nhiệm vụ định kỳ mà không sửa đổi chúng trực tiếp.

Để thực hiện các tác vụ celerybeat must be running.