Tôi đăng ký công việc lên lịch rq trong ứng dụng Django ở đâu?

Question

Tôi muốn sử dụng django_rq và rq-scheduler cho các tác vụ ngoại tuyến, nhưng tôi không chắc chắn về khả năng lập lịch nhiệm vụ lặp lại của rq-scheduler. Ngay bây giờ, tôi đã thêm lịch biểu của mình vào mô-đun tasks.py trong ứng dụng của mình và nhập vào trong __init__ .py. Tuy nhiên, phải có cách tốt hơn để làm điều này, đúng không?

Xin cảm ơn trước.

Answer 1

Tôi đã thêm lịch biểu vào mô-đun __init__ trong một trong các ứng dụng dự án của tôi (về Django), nhưng được bao bọc với chức năng nhỏ ngăn cản việc xếp hàng hai lần trở lên. Chiến lược lập lịch có thể phụ thuộc vào các nhu cầu cụ thể của bạn (nghĩa là bạn có thể cần kiểm tra bổ sung đối số công việc).

Mã làm việc cho tôi và phù hợp với nhu cầu của tôi:

import django_rq 
from collections import defaultdict 
import tasks 

scheduler = django_rq.get_scheduler('default') 

jobs = scheduler.get_jobs() 
functions = defaultdict(lambda: list()) 

map(lambda x: functions[x.func].append(x.meta.get('interval')), jobs) 

now = datetime.datetime.now() 

def schedule_once(func, interval): 
    """ 
    Schedule job once or reschedule when interval changes 
    """ 
    if not func in functions or not interval in functions[func]\ 
      or len(functions[func])>1: 

     # clear all scheduled jobs for this function 
     map(scheduler.cancel, filter(lambda x: x.func==func, jobs)) 

     # schedule with new interval 
     scheduler.schedule(now+datetime.timedelta(seconds=interval), func, 
       interval=interval) 

schedule_once(tasks.some_task_a, interval=60*5) 
schedule_once(tasks.some_task_b, interval=120) 

Ngoài ra tôi đã quấn đoạn này để tránh nhập khẩu ở mức gói:

def init_scheduler(): 
    # paste here initialization code 

init_scheduler() 

Answer 2

Nơi tốt nhất tôi đã tìm thấy để chạy nó từ số AppConfig của bạn trong apps.py.

def ready(self): 
    scheduler = django_rq.get_scheduler('default') 

    # Delete any existing jobs in the scheduler when the app starts up 
    for job in scheduler.get_jobs(): 
     job.delete() 

    # Have 'mytask' run every 5 minutes 
    scheduler.schedule(datetime.utcnow(), 'mytask', interval=60*5) 

Answer 3

Tôi tạo ra một lệnh quản lý tùy chỉnh mà sẽ thay đổi và thay thế lệnh rqscheduler trong django_rq. Một ví dụ được cung cấp tại đây: https://github.com/rq/rq-scheduler/issues/51#issuecomment-362352497