问题标签 [kue]

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 回答
2020 浏览

node.js - 如何在nodejs中管理队列?

我在 Nodejs 中编写了一个脚本,用于截取网站的屏幕截图(使用slimerJs),这个脚本大约需要 10-20 秒才能完成,这里的问题是服务器在这个脚本完成之前停止。

由于该脚本会在内存中生成一个 firefox 浏览器并加载网站,因此 ram 使用量可能会飙升至 600-700mb,因此我无法异步执行此命令,因为 ram 在服务器上很昂贵。

我可以知道是否可以对传入的请求进行排队并以 FIFO 方式执行它们?

我尝试检查 kue、bull 和 bee-queues 等软件包,但我认为这些都假设工作列表在队列开始之前就已经知道,因为我的工作列表取决于使用该网站的用户,我还想告诉人们他们在排队,需要等待轮到他们。上述软件包可以做到这一点吗?

0 投票
1 回答
107 浏览

javascript - Node.js 处理大量图像

我每秒得到大约 20 帧。如果我这样运行它,它会导致计算机死机。我认为这是因为它一次处理大量数据。如何将函数限制为它可以拥有的最大进程数。我查看了 kue,但它需要 redis。我该如何处理?谢谢

js 调用一个 c++ 插件来完成工作。

c++代码

它在这个函数中。

0 投票
1 回答
94 浏览

node.js - Kue 是否使用 Redis 订阅任何 (*) 模式?

我正在尝试使用 Redis 并需要队列来接收来自 Redis 的 nodejs 中的实时通知并发布到连接的客户端。为此,我使用了 Kue。阅读 Redis 文档,您订阅了您感兴趣的频道模式,想知道 Kue 是如何实现这一点的。需要一些指向我可以理解的文档或代码的指针。

0 投票
1 回答
1075 浏览

node.js - 工人在 Kue 中处理多种工作类型

我只是在调查 Kue 作为工作处理者。但是我坚持一个概念:

假设我有多个工人,都可以处理 2 种工作类型中的 1 种。

代码看起来像这样:

这个想法是服务将检查所有队列并启动最高优先级的作业。但我不想在每个工人身上并行处理一种以上的工作类型。

这样做的问题是,如果将“job1”和“job2”同时添加到队列中,则上述过程将并行启动。

实际上,我将拥有“N”个作业类型,每个作业类型都具有可配置的并行运行。我不希望每种工作类型有一个单独的流程,因为这很难扩展。每个进程都应该能够处理任何工作类型。

如何确保任何一个工人一次只能处理 1 批作业类型?

0 投票
1 回答
190 浏览

node.js - kue的工作ID限制是多少?

我的平台是 nodejs 并开始使用 kue 作为队列引擎。到目前为止它工作得很好,我只是好奇它允许的最大工作 ID,因为我每天有数十亿个工作开始。

0 投票
1 回答
558 浏览

javascript - Kue 无法正常处理事件?

我有以下代码用于发送邮件kue

问题是它只响应第一个事件。我必须重新启动脚本才能发送另一个。我在这里做错了吗?

我正在使用添加事件

0 投票
0 回答
99 浏览

javascript - 如何找到最新的 Kue 工作

Kue 是否有一种机制可以找到给定类型的最新工作或给定类型的n 个最新工作?

现有机制似乎只提供按 id 范围查询。

0 投票
1 回答
511 浏览

javascript - 如何在 Kue 中返回 jobID?

我正在使用快递,并且想在有人发布到我的路线时创建工作。我希望响应包含 job.id。但是,作业 ID 仅填充在我的 queue.createFunction 的回调中,所以我不太确定如何返回作业 ID?我能想到的一种解决方案是在我的路线中发出一个发布请求来创建一个工作,因为他们的 api 返回一个 id 作为响应,但这似乎效率低下。

0 投票
1 回答
1320 浏览

javascript - 在 KUE 节点 js 中更新作业状态

我创建一个工作:

有没有办法我可以自己更新工作状态(即活动、失败、进行中)?例如:

消费者接手工作:

这是从上面返回的函数:

我想硬编码一个工作状态,例如job.state = 'failed'并允许自己在我想要的时候更新工作状态?

这在Kue可以吗?

0 投票
4 回答
9667 浏览

node.js - 如何使客户端下载动态生成的非常大的文件

我有一个导出功能,可以读取整个数据库并创建一个包含所有记录的 .xls 文件。然后将文件发送给客户端。

当然,导出全库的时间需要很多时间,请求很快就会以超时错误结束。

处理这种情况的最佳解决方案是什么?

例如,我听说过有关使用 Redis 创建队列的信息,但这需要两个请求:一个用于启动将生成文件的作业,第二个用于下载生成的文件。

这可以通过来自客户端的单个请求来实现吗?