Tag: kue

nodejs Kue作业处理逻辑

我有一个非常简单的逻辑问题。 我将在单独的应用程序服务器上运行作业处理逻辑。 我的工作处理应用程序将是一个独立的应用程序，无所事事只是处理工作。 在我的代码中，如何确保我的应用程序不断检查redis服务器的工作？ – 我需要在无限循环中运行代码吗？ – 或者我需要继续重新启动我的应用程序 或者我在这里失踪的Kue有一些内置的机制？ 谢谢

如何使用Kue在每个星期四安排一次工作？

使用Kue ，我如何安排每周四执行一次工作？ Kue的自述提到我可以推迟一个工作，但是在特定的时间重复执行这个工作呢？ 我可以用cron工作来做我想做的事，但是我喜欢Kue的function。 我想要的是在周四的任何时候处理一次工作，但只有一次。

如何在kue中取回具有特定状态的工作？

我正在使用kue作为我的工作队列，并且我想知道不使用GUI有多less工作仍然存在，有多less失败等。我如何检索这种信息？ 例如，在开始处理作业队列几分钟后，我想将迄今为止失败的所有作业的状态更新为“不活动”，以便重新启动它们。 在stackoverflow上我唯一能find的相关问题就是这个 ，但是，它在处理某个事件之后，一次处理一个工作。 我的关心是不同的，因为我有兴趣检索数据库中的所有工作，具有一定的地位。 这个问题的答案提到了kue库的函数.complete，它检索数据库中所有已完成的作业。 其他可能的工作状态是否有类似的function？

是否有可能在kue节点js中更新已经创build的作业

嗨，我正在使用Kue创造就业机会。 jobs.create('myQueue', { 'title':'test', 'job_id': id ,'params': params } ) .delay(milliseconds) .removeOnComplete( true ) .save(function(err) { if (err) { console.log( 'jobs.create.err', err ); } }); 每个工作都有一个延迟时间，通常是3个小时。 现在我将检查每个传入的请求，要创build一个新的工作，并获得ID。 正如你从上面的代码可以看到，当我创build工作，我将添加作业ID作业。 所以现在我想检查传入的ID与队列中的现有作业的job_id s和更新现有的作业与新PARAMMS如果find一个匹配的ID。 所以我的工作队列将有唯一的job_id每次:)。 可能吗 ？ ，我search了很多，但没有find帮助，我检查了kue json API 。 但它只能创build并获取检索作业，不能更新现有的logging。 提前致谢 。

Node.js Kue如何重启失败的作业

我在我的node.js应用程序中使用kue来延迟作业。 我有一些问题要弄清楚如何使用kue的API重新启动一个作业，而无需手动将作业的ID从失败的作业列表移动到使用redis命令的非活动作业列表。 这可能使用kue吗？ 我不想设置固定次数的重试尝试 – 我只是想重试特定的作业。 一个保持良好的替代kue的build议也是受欢迎的。

如何在Heroku上与Node.js交streamWeb和Worker dynos？

Web Dynos可以处理HTTP请求 当Web Dynos处理它们时， 工作者Dynos可以从中处理作业。 但是我不知道如何让Web Dynos和Worker Dynos互相沟通。 例如，我想通过Web Dynos接收HTTP请求 ，把它发送给工人Dynos ，处理作业并将结果发送给Web Dynos ，在网上展示结果。 这是可能的Node.js？ （用RabbitMQ或Kue等）？ 我在Heroku文档中找不到一个例子 还是应该在Web Dynos中实现所有代码，并只能扩展Web Dynos ？