我正在将项目迁移到
Django
,并且喜欢使用 django-rq
模块。import django_rq
queue = django_rq.get_queue('high')
queue.enqueue(func, foo, bar=baz)
如何致电
func
?这可以是像 path.file.function
这样的字符串吗?创建要包含的tasks.py文件
from django_rq import job
@job("high", timeout=600) # timeout is optional
def your_func(*args, **kwargs):
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)