问题标签 [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.
python - 在烧瓶路由缓存中存储计算
我有一个很长的任务进入 python-rq 工作队列。
我正在flask-cache
尝试将结果保存为它的计算,最多只需要每周运行一次,每月一次也足够了。
我遇到的问题是,当它运行时,它会缓存失败的响应,而不是实际的解决方案。
还有其他方法可以做到这一点吗?或者建议我应该如何处理这个问题?
python - 路由超时,所以 memoize 不起作用
我有当前路线
当我在本地运行它时,它工作正常,因为它不会超时。在结果保存到缓存中并在随后的重新加载时立即加载该函数后,它会立即加载。但是一旦我在运行路由时将它放在服务器上,它就会超时。
即使任务在超时后完成,当我重新加载函数时,它也会重新运行任务,而不是从缓存中调用它。
我应该这样做吗?
flask - TypeError:无法序列化“_io.TextIOWrapper”对象-Flask
我正在编写一个烧瓶应用程序,要求用户上传 excel 电子表格,然后计算并填充数据库。我正在尝试通过Redis RQ在后台执行处理部分,但我不断收到TypeError: cannot serialize '_io.TextIOWrapper' object my代码如下所示:
python - 从 Django 中长时间运行的后台进程获取信息
我想在后台进程(从 redis rq 开始)上运行计算模拟,我可以在其中查询其当前状态,以及使用 Django 更改参数。
为了简单起见:假设我想长时间运行以下代码(我将通过 python 工作者设置):
然后,通过访问一个 URL,它会告诉我value
. 我还可以 POST 到 URL 以更改a
ie的值a=None
以停止模拟或a=-10
更改行为。
做这个的最好方式是什么?
python - 入队调用中的 rq 超时参数不起作用,给出 JobTimeoutException
我正在尝试更改 rq 作业的超时,但似乎没有任何效果。我有一些效果:
但我仍然得到
我非常绝望,甚至尝试进入 rq 模块 queue.py 并将超时的默认参数更改为 2700 和 DEFAULT_TIMEOUT(在 Queue 类中定义的变量,其中包含 enqueue_call 方法)。我是否遗漏了某些东西,或者任何人都知道这个问题?谢谢!
python - 如何自定义python rq的日志系统?
目前 rq 的日志是这样的:-
因此,它也记录了作业的参数,这是一个安全问题,因为参数包含 aws 密钥和访问密钥。有没有办法在 python rq 中解决这个问题?这样它就不会记录参数或任何其他方式
python - 在 rq worker 中使用 ZMQ
我正在尝试zmq
在python-rq
.
如果我context
在任务函数内部创建:
pub.send()
通话什么也不做。
zope - 在 Zope 中使用 python-rq
我正在尝试通过在某个操作后从 ZMI 调用外部方法(用于后台任务)来将 Python-RQ 与 Zope 一起使用。外部方法调用的文件位于 Extensions 中。它初始化与 Redis 的连接并导入一个运行后台任务的模块。问题是这个要导入的文件应该放在哪里?如果我将它放在 Products 目录中,Python-RQ 似乎无法识别。它抛出no module named Products.xyz
。下面是代码片段
rq_worker 函数由外部方法调用。
下面是错误
redis - rq 捕获错误并推送到失败的队列
我正在使用 python-rq 和 redis 来传递域名并从域中获取链接。
每当我运行代码并捕获任何异常时,它都会被推送到失败队列,而不是打印和忽略该域。但在控制台中 rq 不打印pushing to failed queue
。
链接在数据库中得到更新,但域仍然被推送到失败的队列中。并且失败队列的计数超过了默认队列(通过的域总数)。
为什么会这样?请帮忙
python - 从 Flask 中的 RQ 工作人员获取 Sentry 错误
raven.contrib.flask
我有一个使用'sSentry(app, dns=...)
对象注册到哨兵的 Flask 服务器。我还有一些 python-rq 工作人员用于处理异步后台进程。我发现这个文档似乎表明我可以像这样在我的 start_worker 脚本中注册哨兵:
redis_client 是我使用 .redis 连接到 redis 的地方StrictRedis(host=...)
。这些工作人员工作正常,但是当我强制他们正在进行的工作引发异常时,我在 Sentry 上没有看到任何错误,但我在工作人员的错误日志中看到了引发的异常。
我的 Sentry 项目设置为当前允许所有域。为了让这些错误在 Sentry 中正确显示,我需要做些什么特别的事情吗?