from django_rq import job
@job("high", timeout=600) # timeout is optional
def your_func():
pass # do some logic
然后在你的代码中
import django_rq
from tasks import your_func
queue = django_rq.get_queue('high')
queue.enqueue(your_func, foo, bar=baz)
Django-RQ:如何调用函数?
from django_rq import job
@job("high", timeout=600) # timeout is optional
def your_func():
pass # do some logic
然后在你的代码中
import django_rq
from tasks import your_func
queue = django_rq.get_queue('high')
queue.enqueue(your_func, foo, bar=baz)