问题标签 [kue]

我想导出 Kue-api（托管在localhost:3001）并通过 node-express（托管在localhost:3000）访问它。但由于 CORS ，它被阻止了。在典型的节点应用程序中，可以像这样禁用 CORS。

但是 kue in tern 使用 express 并且 app 没有暴露。所以问题是如何在 Kue 中禁用 CORS

我试过这个

I have set up kue to run with the Cluster module, which spawns a child process of kue for every CPU core available..

When the scheduler inserts the every keys to redis, everything seems to be in order - only a single keyset for every every run.

However, when the time to trigger the job processing comes, all child processes (workers) start handling the processing logic, which results in the job having multiple instances triggered from a single "scheduler" entry.

This symptom does not seem to happen when programmatically triggering a new job in kue, nor does it happen when using the kue API to do so.

Please advise.

Main Bootstrap Code

init.js

scheduler.js

• job_types - contains the kue jobs.process('job type',...) methods to handle all the job logic itself.

我开始使用 kue/node.js 。我检查了一个教程，它有这个代码

所以当我从我的终端节点 test.js 运行它时，我将每 3 秒输出一次“job { job id } is done”。

现在我将代码更改为以下

我删除了 newJob 函数和 setInterval ，我希望代码会运行一次，因为我先创建队列并保存作业，然后我将在下面处理它。但是当我从终端运行代码时没有任何反应，没有输出。

为什么我没有得到预期的结果？这背后的逻辑是什么。请解释 。提前致谢 。

我目前正在使用 kue / node.js

https://github.com/Automattic/kue

创建并保存作业后，数据将在我的本地 redis 服务器中。

Redis CLI

现在我重新启动机器并再次检查后，

所以它是空的。

这很明显，但我想保留数据，我检查了 kue 文档但我找不到任何东西？

有没有办法做到这一点。

提前致谢 。

嗨，我正在使用kue、cluster、redis、node.js。这是一个非常简单的例子，稍后我将从外部调用测试函数。

我的目的是将一些传入的作业添加到队列中并使用 workers 处理它。

在我的情况下，当用户使用我的应用程序完成订单时，他会收到一封电子邮件。我会将电子邮件详细信息发送到队列并使用工作人员处理它。

当我运行脚本时，node test.js我得到了这个输出

并继续....

所以我可以看到，主进程不时运行，并且再次 fork() 子进程，并且工作也正在完成。

我的问题是

• 这是正确的模型吗？（我的目的是将一些传入的作业添加到队列中并使用工人处理它）
• 每次我使用 jobs.create() 创建作业时，我的作业队列是重新创建还是只是将新作业附加到现有队列？
• 当主进程再次派生子进程时，如果一个工作人员正在做一些工作，他会完成这项工作还是该工作将停止未完成？

几天我试图自己理解但仍然有疑问，如果有人能解释这些背后的逻辑，我将不胜感激:)

提前致谢 。

js/快递。我正在做的是从另一台服务器向快递服务器发送一个请求，其中包含一些用户详细信息。

将请求详细信息添加到作业队列（kue），然后使用工人（集群）处理作业并向用户发送电子邮件。我想将响应发送回服务器，服务器将请求发送到我的快递服务器。

正常res.send()在这里不起作用，因为在我们将请求参数添加到队列并处理之后，请求和响应之间没有链接。这是我的代码示例。

应用程序.js

有一个新要求： 现在我需要创建电子邮件 html 并将其发送回请求者，而不是发送电子邮件。

如果我不使用作业队列，我可以使用 res.send() 。但现在我不能。

我考虑将我的res对象保存到作业队列，然后最近尝试使用该响应对象将响应发送回同一用户。

在这种情况下我可以使用任何解决方案吗？

任何帮助是极大的赞赏 ：）

我正在使用Kue创建工作。

每个工作都有延迟时间，一般是3小时。

现在我将检查每个想要创建新作业并获取 id 的传入请求。

从上面的代码可以看出，当我创建一个作业时，我会将作业 ID 添加到作业中。

所以现在我想用队列中现有作业的 job_id 检查传入的 id，如果找到匹配的 id，则使用新参数更新现有作业。

所以我的工作队列每次都会有唯一的 job_id :)。

是否可以？我搜索了很多，但没有找到任何帮助。我检查了 kue JSON API。但它只能创建和获取检索作业，不能更新现有记录。

我正在我的nodejs应用程序中使用Kue实现redis队列。我有一个 API，可以将电子邮件添加到. 让 cron 作业监听新作业是一种好习惯，还是有一种方法可以在输入新电子邮件并从单独的应用程序捕获以处理它时从应用程序触发事件。我对正确的方法有点困惑。jobsemail queueredis email queuenode.jsjobnode.js

在以下情况下，我经常收到此错误：

1. 在浏览器窗口中打开 kui-ui 仪表板
2. 执行正常关机

我不确定它是否应该为Queue.client空。如果是，那么应该在调用之前Queue.prototype.card先检查是否存在。与this.clientthis.client.cardQueue.prototype.cardByType

这是我的 api 路由dashboard/stop代码（即停止进程并刷新缓存）：

注意：queue是Kue和client的一个实例redis：

github上也提出了相同的问题（issue）：

1. https://github.com/Automattic/kue/issues/825
2. https://github.com/StreetHub/kue-ui/issues/23

而且还没反应。。

任何想法/想法！如何得到这个修复..？

我正在尝试将 kue 用于我的 Parse 服务器（托管在 heroku 上）上的预定作业。现在我已经修改了我的index.js文件，就像我发现的关于 Kue 的几个教程中所述：

我发现该应用程序在以下行崩溃：.use(kue.app)。这是我得到的错误：

我不知道为什么会这样。