问题标签 [python-rq]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
1126 浏览

python - 在烧瓶路由缓存中存储计算

我有一个很长的任务进入 python-rq 工作队列。

我正在flask-cache尝试将结果保存为它的计算,最多只需要每周运行一次,每月一次也足够了。

我遇到的问题是,当它运行时,它会缓存失败的响应,而不是实际的解决方案。

还有其他方法可以做到这一点吗?或者建议我应该如何处理这个问题?

0 投票
1 回答
56 浏览

python - 路由超时,所以 memoize 不起作用

我有当前路线

当我在本地运行它时,它工作正常,因为它不会超时。在结果保存到缓存中并在随后的重新加载时立即加载该函数后,它会立即加载。但是一旦我在运行路由时将它放在服务器上,它就会超时。

即使任务在超时后完成,当我重新加载函数时,它也会重新运行任务,而不是从缓存中调用它。

我应该这样做吗?

0 投票
0 回答
3180 浏览

flask - TypeError:无法序列化“_io.TextIOWrapper”对象-Flask

我正在编写一个烧瓶应用程序,要求用户上传 excel 电子表格,然后计算并填充数据库。我正在尝试通过Redis RQ在后台执行处理部分,但我不断收到TypeError: cannot serialize '_io.TextIOWrapper' object my代码如下所示:

0 投票
1 回答
172 浏览

python - 从 Django 中长时间运行的后台进程获取信息

我想在后台进程(从 redis rq 开始)上运行计算模拟,我可以在其中查询其当前状态,以及使用 Django 更改参数。

为了简单起见:假设我想长时间运行以下代码(我将通过 python 工作者设置):

然后,通过访问一个 URL,它会告诉我value. 我还可以 POST 到 URL 以更改aie的值a=None以停止模拟或a=-10更改行为。

做这个的最好方式是什么?

0 投票
3 回答
5874 浏览

python - 入队调用中的 rq 超时参数不起作用,给出 JobTimeoutException

我正在尝试更改 rq 作业的超时,但似乎没有任何效果。我有一些效果:

但我仍然得到

我非常绝望,甚至尝试进入 rq 模块 queue.py 并将超时的默认参数更改为 2700 和 DEFAULT_TIMEOUT(在 Queue 类中定义的变量,其中包含 enqueue_call 方法)。我是否遗漏了某些东西,或者任何人都知道这个问题?谢谢!

0 投票
3 回答
4025 浏览

python - 如何自定义python rq的日志系统?

目前 rq 的日志是这样的:-

因此,它也记录了作业的参数,这是一个安全问题,因为参数包含 aws 密钥和访问密钥。有没有办法在 python rq 中解决这个问题?这样它就不会记录参数或任何其他方式

0 投票
1 回答
97 浏览

python - 在 rq worker 中使用 ZMQ

我正在尝试zmqpython-rq.

如果我context在任务函数内部创建:

pub.send()通话什么也不做。

0 投票
0 回答
69 浏览

zope - 在 Zope 中使用 python-rq

我正在尝试通过在某个操作后从 ZMI 调用外部方法(用于后台任务)来将 Python-RQ 与 Zope 一起使用。外部方法调用的文件位于 Extensions 中。它初始化与 Redis 的连接并导入一个运行后台任务的模块。问题是这个要导入的文件应该放在哪里?如果我将它放在 Products 目录中,Python-RQ 似乎无法识别。它抛出no module named Products.xyz。下面是代码片段

rq_worker 函数由外部方法调用。

下面是错误

0 投票
0 回答
621 浏览

redis - rq 捕获错误并推送到失败的队列

我正在使用 python-rq 和 redis 来传递域名并从域中获取链接。

每当我运行代码并捕获任何异常时,它都会被推送到失败队列,而不是打印和忽略该域。但在控制台中 rq 不打印pushing to failed queue

链接在数据库中得到更新,但域仍然被推送到失败的队列中。并且失败队列的计数超过了默认队列(通过的域总数)。

为什么会这样?请帮忙

0 投票
0 回答
496 浏览

python - 从 Flask 中的 RQ 工作人员获取 Sentry 错误

raven.contrib.flask我有一个使用'sSentry(app, dns=...)对象注册到哨兵的 Flask 服务器。我还有一些 python-rq 工作人员用于处理异步后台进程。我发现这个文档似乎表明我可以像这样在我的 start_worker 脚本中注册哨兵:

redis_client 是我使用 .redis 连接到 redis 的地方StrictRedis(host=...)。这些工作人员工作正常,但是当我强制他们正在进行的工作引发异常时,我在 Sentry 上没有看到任何错误,但我在工作人员的错误日志中看到了引发的异常。

我的 Sentry 项目设置为当前允许所有域。为了让这些错误在 Sentry 中正确显示,我需要做些什么特别的事情吗?