问题标签 [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的redis CLIENT LIST中的多个连接
使用 python RQ 并启动一个工作进程，向它传递一个打开的 redis 连接，我看到两个使用 CLIENT LIST 的连接：
其中一个有cmd=subscribe，另一个有cmd=blpop。想知道这里发生了什么？我认为 python RQ 应该只使用单个 Redis 连接，但看起来它使用了两个？
redis - 通过 ID django_rq 重新排队特定作业
我找不到直接的答案，是否可以仅根据作业的 redis id 重试作业？我想在 Django 中创建一个可以手动重试特定作业的端点，因为我并不总是需要失败的作业来重试自己。
对于我想要做的事情，一个例子可能更清楚：
urls.py：
views.py：
python - 刷新 RQ 作业的 result_ttl
有没有办法刷新result_ttlRQ 作业？例如：我result_ttl是 500 秒，如果我在 500 秒内再次请求结果，我会再次将 TTL 刷新到 500 秒。
python - RQ Custom Worker 无法在 Docker Compose Env 中启动作业
我有一个基于烧瓶的 Web 应用程序，客户端发送 POST 请求以提交图像以在其上运行 YOLO。然后，客户端定期发送 GET 请求以获取分类结果。
我能够在不使用任何 docker 的情况下运行代码。但是，当我尝试在 docker compose 内部运行时，我的工作人员无法工作。这是 docker-compose 文件：
以下是源文件的一些详细信息： app.py：包含烧瓶服务器，提供 POST 和 GET 服务，将作业添加到 redis 队列。worker.py：设置 RQ worker req.py：客户端代码
工人.py：
app.py 有 get_prediction2()，worker 试图执行它：
这是我在运行“sudo docker-compose up”时收到的错误消息：
不确定设计自定义 rq worker 的正确方法是什么。我看到这个链接中有一些建议：https ://python-rq.org/docs/#considerations-for-jobs
python - Python rq 模块：AttributeError：“元组”对象没有属性“__module__”
我正在尝试使用 rq 模块生成的队列来测试对 Flask 服务器的发布请求。Rq的队列不断提示这个奇怪的错误：
我很乐意获得有关此错误的帮助。这些是我的文件：transmitter.py：
接收服务器.py：
全局变量.py
测试2.py：
我尝试更改testPost函数几次，但错误不断出现...请帮我解决这个问题！
python - RedisQueue 将超时设置为 -1 并且作业在运行时仍会转到 FailedJobRegistry
我已将超时设置为 -1，但作业在运行时仍会转到 FailedJobRegistry
同时，worker仍在运行
最初它没有添加到 FailedJobs 中（它在 running_job_ids 中），但过了一段时间它就到了那里
当工人完成它的任务
job_id 仍然在FailedJobRegistry但在这里它提出了
rq.exceptions.NoSuchJobError: No such job: b'rq:job:xxxxxxxxxxxxxxxxxxxxxxxxxxxx'
18:26:34工人已启动
18:28:25工人已添加到 FailedRegistry
但工人正在运行并稍后成功完成任务18:34:12
python - 有什么更好的方法来创建 redis - rq 微服务容器，从其他独立容器发布事件？
如果我们使用微服务架构，理想情况下单个函数定义应该在一个地方。
因此，如果我有一个包含订阅者功能的微服务。
我想从任何微服务向该订阅者发布一个事件。当它甚至在任何其他微服务中都不可用时，我将如何传递该函数的实例。
我的 API 服务器基于烧瓶，我的脚本是一个单独的微服务容器，下面是我正在遵循的架构。
是否有更好的设计模式资源？请告诉我。
更新 -
这个回购确实有意义 - https://github1s.com/munisisazade/redis-pub-sub/
有评论吗？
python - RQ：使用 `@job` 装饰器时的成功和失败处理
我正在使用@job装饰器来定义如下任务：
当我称它为add.delay(100, 100). 但我需要为我的工作提供成功和回调处理程序。当我将我的工作定义为@job(queue=rqueue, on_success=my_callback_func)失败并显示一条消息说它得到了一个意外的关键字参数时on_success。
如果我像下面这样将工作排入队列，它会顺利运行：
我还尝试使用函数传递回调处理程序，delay但没有运气。
请帮忙 ！！！
python-3.x - 我们可以在 RQ 调度器中检索最初在 scheduler.Schedule() （如 Args）中传递的参数吗？
我想要的是：
我正在尝试在调度时检索我在 rq 调度程序中传递给我的作业的参数，例如：传递的参数、函数名称和其他内容
我已经尝试过的：
显示错误
python - 为python rq创建一个装饰器来排队任务
我正在尝试创建一个装饰器，它将自动对某些功能进行排队。
然后我有一些功能可以说，
但是，这不起作用，因为入队的函数是 fire_and_forget 函数，该函数将另一个 fire_and_forget 函数入队，依此类推。工人们不停地排着队。
有什么办法解决这个问题？我一直试图弄清楚几个小时无济于事：\