Django-RQ：如何调用函数？

一尘不染

redis

我正在将项目迁移到Django并喜欢使用该 django-rq 模块。
但是，我坚持要放在这里：

import django_rq
queue = django_rq.get_queue('high')
queue.enqueue(func, foo, bar=baz)

怎么打电话func？可以是这样的字符串path.file.function吗？
函数是否需要驻留在同一文件中？

阅读 412

2020-06-20

共1个答案

一尘不染

创建task.py文件以包括

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)

2020-06-20