问题标签 [kue]

我尝试通过带有 Kue 的作业队列生成一个执行 cpu 密集型计算的子进程。我目前的代码如下所示：

消费者.js

代码在某种程度上做了我想做的事情，但是有没有更好的方法来报告工作失败（给 Kue）并从生成的进程中获取标准错误？

我像往常一样设置了 kue 工作：

在某些情况下，我希望作业失败并自动重新启动。为此，我的处理器中有以下几行：

我尝试将失败的事件更改为：

如此处建议：Node.js Kue 如何重新启动失败的作业

我还尝试像在自述文件中一样添加尝试（） ，如下所示：

这些事情都没有奏效。该作业被标记为“失败”，我的控制台显示“问题”，但我没有看到“失败”侦听器中定义的消息。

编辑

经过更多阅读，我尝试在队列级别收听“作业失败”事件，使用：

同样的结果，并且没有控制台日志......这似乎是 Kue 以外的东西，知道什么可以使事件不触发吗？

要求很简单，在 kue 中创建具有给定优先级的作业后，是否可以renice在计划运行之前更改其优先级（如在 POSIX 中）？

是否可以在 KUE https://github.com/LearnBoost/kue中将脚本作为作业排队和执行？

类似脚本/usr/bin/myScript.sh -a 10 -b 20 -c 30
我见过的所有示例都假设作业被定义为 Node.js 函数。

如果可能，我如何定义作业名称、脚本路径和脚本参数？

对于相同的任务，是否有比 KUE 更好的替代方案。
最好具有 UI 和小内存占用。:)

我有一个关于在 Heroku 上扩展 SailJS 应用程序的问题。

设置：

• 帆JS
• Kue（Redis 排队系统）
• 通过套接字 io (sailsjs) 连接客户端
• 2 个测功机（每个运行一个 SailsJS 实例）
• CronJob 类进程

我想自主运行一个连续的“cron”进程，该进程触发一个推送消息，该消息必须发送到连接的 socketio 客户端。当正确配置时，我知道套接字连接驻留在 Redis 中。

我将kue用于 nodejs，并触发一个工作人员来处理任务。worker 位于 SailsJS 实例中，能够向连接的套接字客户端发送推送消息。

但我想知道，不是每个 SailsJS 实例（dyno）都有相同的连接套接字，对吧？换句话说，每个 SailsJS 实例是否都有相同的连接套接字客户端可用，或者 dyno1 是否有一组连接的客户端，而另一个 dyno 有另一组客户端？

例如：

如何解决这个问题... :-D？

我无法使用 kue 连接到 Redis，我按照这篇文章，实际上我正在使用 kue redis 客户端创建连接，连接代码是这样的：

似乎 Kue 正在尝试连接到本地 Redis（我没有安装），因为我遇到了这个异常：

错误：与 127.0.0.1:6379 的 Redis 连接失败 - 连接 ECONNREFUSED

我已经阅读了这篇文章，似乎问题已在 0.8 版中得到解决，我正在使用 0.8.11 :/，最后我还想通过使用redis nodejs来覆盖使用不同客户端实例的客户端，但没有任何运气，因为我遇到了同样的错误。

任何帮助将不胜感激。谢谢！

我已经安装了 Kue 及其所有依赖项。正在运行

nodejs testing.js

出现以下错误

测试代码与kue中可用的代码相同。'describe' 没有在 kue 中定义吗？我在这里缺少什么

我有一个以固定间隔（每分钟）创建一批新作业的进程，我想将它们发送到 kue 以供另一个进程处理。

有时，同一个作业可以分批进行。

如果在前一批中发送的作业在新批次中再次发送时尚未完成，会发生什么情况？

我的理解是它将被视为一项新工作并执行两次。

这是正确的，有没有办法避免这种情况？

在具有多个实例（例如 docker 中的多个容器）且都使用相同的 redis 数据库的应用程序中使用 kue 时，如果您暂停工作人员，您需要在所有实例上暂停该工作人员还是在 redis 级别处理该工作人员？因此为您处理？

https://github.com/Automattic/kue#pause-processing

如果我们不必使用任何实例到实例的通信来让所有工作人员暂停，那就太好了。

我想将来自 Kue ( https://github.com/Automattic/kue ) 的 UI 与我的 Hapi.js 应用程序并行使用。

Kui UI 是用 Express 构建的。

Hapi 和 Express 正在我的 heroku dyno 上的 80 端口上监听。

我怎样才能做到这一点？有人可以给我一个例子吗？