将失败的任务保存到Redis并重新入队。
项目描述
# 队列-重新入队
将失败的任务保存到Redis并重新入队。
## 安装
$ pip install kuyruk-requeue
## 使用
```python
from kuyruk import Kuyruk, Config
from kuyruk_requeue import Requeue
config = Config()
config.REDIS_HOST = "localhost"
config.REDIS_PORT = 6379
config.REDIS_DB = 0
config.REDIS_PASSWORD = None
kuyruk = kuyruk.Kuyruk(config)
Requeue(kuyruk)
@kuyruk.task
def oops()
1/0 # 失败的任务将被保存到Redis
```
运行命令重新入队保存的任务
$ kuyruk --app ... requeue
将失败的任务保存到Redis并重新入队。
## 安装
$ pip install kuyruk-requeue
## 使用
```python
from kuyruk import Kuyruk, Config
from kuyruk_requeue import Requeue
config = Config()
config.REDIS_HOST = "localhost"
config.REDIS_PORT = 6379
config.REDIS_DB = 0
config.REDIS_PASSWORD = None
kuyruk = kuyruk.Kuyruk(config)
Requeue(kuyruk)
@kuyruk.task
def oops()
1/0 # 失败的任务将被保存到Redis
```
运行命令重新入队保存的任务
$ kuyruk --app ... requeue
