djangoアプリケーションでrq-schedulerジョブをどこに登録しますか？

Question

私はdjango_rqとrq-schedulerをオフラインタスクに使用したいと思いますが、私はrq-schedulerのどこに繰り返しタスクをスケジューリングするかは分かりません。今、自分のアプリケーション内のtasks.pyモジュールにスケジューリングを追加し、それを__init__ .pyにインポートします。しかし、これを行うにはよりよい方法が必要です。

ありがとうございます。

Answer 1

私のプロジェクトアプリケーション（Djangoに関して）の__init__モジュールにスケジューリングを追加しましたが、キューイングジョブが2回以上行われないように小さな関数でラップされています。スケジュール設定の戦略は、ニーズに応じて異なる場合があります（ジョブの引数を追加で確認する必要があります）。

私の作品と私のニーズに合うコード：

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) 

また、私はパッケージレベルでの輸入を避けるために、このスニペットを包みました：

def init_scheduler(): 
    # paste here initialization code 

init_scheduler() 

Answer 2

私が見つけた最高の場所をそれを実行するにはAppConfigの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

私はdjango_rqに含まrqschedulerコマンドを変更し、置き換えるカスタム管理コマンドを作成しました。例を以下に示します。https://github.com/rq/rq-scheduler/issues/51#issuecomment-362352497