问题标签 [kue]

当我将一些作业放入kue然后我重新启动时redis，排队的作业就会消失。我认为这是正常行为，但我想知道是否有办法在redis重启后保留排队的作业？我的应用程序需要处理所有作业，因此我需要一个函数/方法将作业添加到队列中，以保证作业实际上已添加到队列中，并且在处理之前它将一直保留在那里......

kue那么在节点中或在其他节点中是否有任何机制job queueing library？或者我必须通过将每个作业存储在 DB 中然后将作业从 db 添加到 kue 来自己处理它？

我目前正在为自己开发一个需要在后台处理内容的项目，但是，我需要在 Express 和 Kue 之间进行通信。但是关于当前设置的更多信息：我的 Express.js 在主机内分叉了超过一半的 CPU。这一切都按预期工作。现在我运行另一个节点进程，它运行 kue.js 进行后台游行。由于 kue 通过 redis 安排其作业，我现在的主要问题是如何将数据从已处理的后台作业发送回我的主要 node.js 应用程序。

我的设置的简短概述：

app.js（与节点 app.js 一起运行）

background.js（也与节点 background.js 一起运行，这与应用程序不同的节点进程）

有人对此有想法吗？感谢您的每一次帮助。

真诚的，克里斯平

我的应用程序需要进行一些 CPU 密集型处理，所以我正在考虑将其作为后台工作。

我希望 express 应用程序和 kue 都在同一个盒子（不同的内核）上运行。我怎么做？主应用程序和作业队列如何相互通信？它们在同一个盒子上，所以发送一个 http 请求似乎很浪费。

我见过这样的问题，但他们没有回答我的问题。

我有一个功能

我怎样才能使它在完成callback时被调用jobs.process('job', function(job, done){ ...？

使用 nodejs 和 kue，我想将一个长时间运行的作业插入队列并忘记它。工人将处理所有细节。

简短的例子：

该作业已创建（并单独处理），但生产者进程在没有中断信号的情况下不会退出。

我不希望生产者进程保持资源或连接打开。我不想听工作事件。我希望有一种“一劳永逸”的方法。

kue会这样做吗？如何？

谢谢！

编辑：

1：添加：lsof -p 显示到端口 6379（redis 服务器）的开放 tcp 连接

2：我也尝试在关机回调中调用 job.client.quit() 。

是否有任何已知的 API 可用于获取 Kue 中的工作数量？例如，我想获得非活动工作的数量。

现在我有这部分代码可以获取 JOBS。

我可以使用 selectedJobs.length。但是，从性能角度来看，这是不好的形式。

提前致谢

我想将哨兵监控连接到我的 kue 应用程序。应该怎么做？我在文档中看到如何为普通的 node.js 做到这一点：

但我想要表达风格：

这样哨兵就会为我捕获错误，而不是手动调用 client.captureError。也许这很简单，我是第一次使用 kue，将不胜感激。

谢谢。

我正在使用使用node_redis的kue，但我也已经在使用我的会话，所以我想在特定端口上创建一个服务器，比如默认值，然后在 port 上监听。node_rediskue6379kue1234

我怎么能做到这一点？我发现这篇文章谈到了类似的事情，但我真的不想创建一个初始化脚本来做到这一点。

我不太确定如何解决这个问题，但这对我来说很烦人，而且在生产中搞砸了。在用户完成某事后，我正在使用 kue.js 完成一项任务。我网站上最典型的案例是上传图片和发送电子邮件。

它在大多数情况下都有效，但在其他时候，似乎某些工作可能无法完成，或者它们的顺序很奇怪，因此当它们真正完成时，从它们返回的数据是无序的，所以当它执行在任务的回调中更新数据库，它会写入错误的图像。

一般来说，我对工作队列很陌生，所以如果我遗漏了一些明显的东西，请不要伤害我。我应该怎么做才能确保不会发生这种情况，或者这只是队列的性质？

我需要根据用户上传到我的节点/快递服务器的输入文件执行一些“大量”计算，并限制同时运行的计算数量。计算由 Fortran 90 程序完成（运行时间为 30-90 分钟）。

我一直在查看 Kue ( https://github.com/LearnBoost/kue ) 来创建作业队列，但我对可以做什么感到有些困惑：

• 我可以让一个单独的服务器运行计算，使用例如 python 程序开始计算（然后如何“获取”工作？）？或者我应该运行一个节点服务器，然后用计算启动一个子进程？