python - 如何从代码中读取失败队列(rq)的回溯？-6ren

python - 如何从代码中读取失败队列(rq)的回溯？

转载作者：IT王子更新时间：2023-10-29 06:03:21

32

4

我在失败队列中有 1 个失败的作业。

$ rq info
failed       |█ 1

1 queues, 1 jobs total

作为answered @Byron Ruth，我可以通过这种方式获得该号码:

from rq import Queue
from redis import Redis

q = Queue('failed', connection=Redis())
print len (q.jobs)

在 rq-dashboard 上，我看到了回溯:

Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/rq/worker.py", line 588, in perform_job
    rv = job.perform()
    ...

如何使用 Python 代码获取此回溯？如果那不可能，任何编程解决方案都是可以接受的(例如通过 Bash)。

最佳答案

不确定您是否找到了解决方案。您可以从 exc_info 调用中获取回溯。例如:

>>> print(get_failed_queue().jobs[0].exc_info)
Traceback (most recent call last):
  File "/Users/ubuntu/.venv/lib/python3.5/site-packages/rq/worker.py", line 700, in perform_job
    rv = job.perform()
  File "/Users/ubuntu/.venv/lib/python3.5/site-packages/rq/job.py", line 500, in perform
    self._result = self.func(*self.args, **self.kwargs)
  File "/Users/ubuntu/foo.py", line 17, in foobar
    1/0
ZeroDivisionError: division by zero

关于python - 如何从代码中读取失败队列(rq)的回溯？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40462757/

32

4

0

文章推荐： REDIS如何从 key 中删除过期时间

文章推荐： javascript - Javascript 中的构造函数属性是否有好的用例？

文章推荐： linux - 为 Redis 3.2.6 调整 Linux 内核堆栈

python-rq - 如何使用 python-rq 明确地为队列赋予优先级
我正在尝试 python-rq，但我没有看到如何明确地为队列赋予优先级？优先级是否来自工作人员启动时定义的顺序？ rqworker queueA queueB queueC 与 queueB 和 q
python-rq - 如何获取有关在远程 Redis 上工作的 rq 工作人员的信息
我正在尝试运行rq info命令，但我想获取远程redis机器上的信息。如何指定redis机器的url？最佳答案事实证明这很简单但没有记录: rq info --url redis://my-se
python - 在 Django 中测试 django-rq ( python-rq ) 的最佳实践
我将开始在我的项目中使用 django-rq。 Django integration with RQ, a Redis based Python queuing library. 测试使用 RQ 的
python - NGINX/Gunicorn/Django-RQ : How to log each rq-worker to a different file
我们正在使用 NGINX + Gunicorn + Django + RQ 的架构，有几个 rq-worker。我们使用基本的 Django 日志记录设置(如下)，具有翻转和最大文件大小，但是: 创建
python - RQ 超时不会终止多线程作业
我在使用 python RQ 运行多线程任务时遇到问题(在 v0.5.6 和 v0.6.0 上测试)。考虑以下代码，作为我想要实现的目标的简化版本: 事物.py from threading imp
Django rq 做批量数据库插入
如何入队一个会运行很长时间的函数？我想做以下事情: def batch_insert(数据): rows.append(MyModel(*data)) 如果 len(行) > 1000: MyMod
Python/rq - 监控工作人员状态
如果这是一个愚蠢的问题，我道歉并会羞愧地把头藏起来，但是: 我正在使用 rq 在 Python 中对作业进行排队。我希望它像这样工作: 工作 A 开始。作业 A 通过 Web API 抓取数据并存储。
Python/rq - 如何将信息从调用者传递给工作人员？
我想使用 rq 在单独的 worker 上运行任务以从测量仪器收集数据。用户按下 dash 应用程序上的按钮将发出任务结束信号。问题在于任务本身不知道何时终止，因为它无权访问 dash 应用程序的上下
python - RQ - 清空和删除队列
我正在使用 RQ ，并且我有一个包含数千个项目的 failed 队列，以及我不久前创建的另一个 test 队列用于测试，现在是空的且未使用。我想知道如何从 failed 队列中删除所有作业，并完全删除
r - summary.rq 输出取决于样本大小
我发现(见下文)函数 summary.rq (第 88 页)来自 quantreg 包打印不同的输出，这取决于样本量是大于等于还是小于 1001。我知道，rq() 使用不同的方法，具体取决于样本大小
python rq worker 并行执行任务
我对python rq不是很了解，我刚开始学习它。有一个 task_a 需要 3 分钟才能完成处理。 @job def task_a(): time.sleep(180) print
python - RQ-dashboard 上报空载时间数据
我正在尝试使用 Redis 队列和 RQ 调度程序构建作业队列。但是当我尝试加载作业选项卡时，我从 RQ-dashboard 收到以下错误。我看到工作已添加，因为工作数量在增加。 During han
python rq - 如何在完成多个其他作业时触发作业？多工作依赖工作？
我的 python redis 队列中有一个嵌套的作业结构。首先执行 rncopy 作业。完成后，接下来是 3 个相关的注册作业。当所有这 3 个作业的计算完成后，我想触发一个作业向我的前端发送 we
python-rq worker 不读取队列中的作业
我在设置 python-rq 时遇到了一个基本问题 - rqworker 似乎无法识别推送到它正在监听的队列的作业。一切都在 virtualenv 中运行我有以下代码: from redis imp
python - 如何将设置传递给 rq 任务？
我想知道将设置从 RQ worker 传递到任务函数的最佳方法是什么？我想将我的所有设置保存在应用程序之外的文本文件中，然后在工作人员启动时读取它，然后使用这些值来执行实际任务。现在我正在使用 o
python - 如何获取 rq 队列中的作业数？
我正在使用 rq和 RedisToGo。如何获取队列中的作业数？我在文档中找不到它？ (在 Python 中) 当我尝试时: print "Before: ", len(q.jobs) result
python - 将装饰器的函数传递给 Python RQ
如何将装饰器的函数传递给作业？我有一个装饰器可以使用该函数运行作业。 @job def queueFunction(passedFunction, *args, **kwargs): # D
Django RQ rqworker 无限期卡住
本周，我的集成测试停止工作。我发现这是一个无限期停滞的 django-rq 工作。我的输出: $: RQ worker 'rq:worker:47e0aaf280be.13' started, ver
python RQ : pattern for callback
我现在有大量文档要处理，我正在使用 Python RQ 来并行处理任务。我希望在每个文档上执行不同的操作时完成一系列工作。例如:A -> B -> C 表示将文档传递给函数A，在之后A 已完成，继续
python - 在 RQ 中排队实例方法或对象？
因此，RQ 明确声明我可以将对象的实例方法入队 here ，所以我一直在尝试这样做，但得到了一个 PicklingError: q.enqueue(some_obj.some_func, some_d

首页

博学

6Ren·AI

商城

python - 如何从代码中读取失败队列(rq)的回溯？