问题标签 [django-rq]

I'm trying to implement the django-rq since I have some scraping that sometimes fails and has to be scheduled to run again after, say, 30 seconds.

As far as I understand, I push a job the queue by

is there a way to push it to the queue and give it

1. A timestamp to run (like Airflow) e.g 0 01 * * *

or

2. a time-delay before run (e.g 30 sec)

这个问题很可能是因为我对 django-RQ/redis 的工作原理有误解。我一直在使用 django-rq 来运行/缓存长时间运行的进程，效果很好。但是，我们现在需要将其中一些进程拆分到不同的队列中。

文档使这看起来很容易。但是，尝试将任务发送到专业队列时出现以下错误：无法解析 Redis 连接我认为这可能是因为我对两个队列使用了相同的连接信息，但我看到了其他示例做同样的事情（https://newbedev.com/how-to-create-multiple-workers-in-python-rq）。

我哪里做错了？（我包括了本地和 heroku 设置，因为两者都存在相同的问题）。

我找不到直接的答案，是否可以仅根据作业的 redis id 重试作业？我想在 Django 中创建一个可以手动重试特定作业的端点，因为我并不总是需要失败的作业来重试自己。

对于我想要做的事情，一个例子可能更清楚：

urls.py：

views.py：

我在三个不同的队列上设置了多个工作人员的 django-rq。我希望在方法完成后在特定队列上完成的作业具有额外的逻辑（基本上mail_admins在作业完成后添加）。

我发现的唯一方法是从rq.job.Job类继承并在那里添加这个逻辑。但是Job类是为所有队列而不是每个队列设置的。

我正在运行这个脚本来测试我的 docker 容器上的 I/O 性能。

奇怪的是执行时间因容器而异

• 在容器 1 上：65.96740865707397 秒
• 在容器 2 上：71.00589632987976 秒

这两个容器之间唯一不同的是 docker 执行的命令：

• 容器 1 命令是：./manage.py runserver 0.0.0.0:80（这是 django）
• 容器 2 命令是：python3 manage.py rqworker my_queue（这是 django_rq）

你知道为什么我有 5 秒的差异吗？或者你知道我在哪里可以调查？