基于RQ的异步任务,在执行的过程中报错时,允许设置重试的次数和间隔。
import django_rq
from rq.job import Retry
# 允许重试5次,每次间隔5秒
retry = Retry(max=5, interval=5)
queue = django_rq.get_queue('default')
# func是方法名
queue.enqueue(func, retry=retry)
注意:运行代码前,先启动Django-rq
python manage.py rqworker default