Dove posso registrare un lavoro rq-scheduler in un'app Django?

Question

Mi piacerebbe utilizzare django_rq e rq-scheduler per le attività offline, ma non sono sicuro di dove chiamare la capacità di rq-scheduler di pianificare attività ripetitive. In questo momento, ho aggiunto la mia pianificazione a un modulo tasks.py nella mia app e l'ho importato in __init__ .py. Deve esserci un modo migliore per farlo, però, giusto?

Grazie in anticipo.

Answer 1

Ho aggiunto la pianificazione a un modulo __init__ in una delle mie applicazioni di progetto (in termini di Django), ma avvolto con una piccola funzione che impedisce l'accodamento di due o più processi. La strategia di pianificazione può dipendere dalle vostre esigenze specifiche (ad esempio, potrebbe essere necessario un controllo aggiuntivo per gli argomenti di un lavoro).

codice che funziona per me e adatta alle mie esigenze:

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) 

Inoltre ho avvolto questo frammento di evitare importazioni a livello di pacchetto:

def init_scheduler(): 
    # paste here initialization code 

init_scheduler() 

Answer 2

Il posto migliore che ho trovato per eseguirlo è dal tuo AppConfig in 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

ho creato un comando di gestione personalizzato che modifica e sostituisce il comando rqscheduler incluso nel django_rq. Un esempio è fornito qui: https://github.com/rq/rq-scheduler/issues/51#issuecomment-362352497