标签: job-queue

我是 Bull 的新手。我尝试根据他们的文档代码运行 bull。流程正在启动，但我的工作尚未完成，或者不确定它是否触发完成事件？我不确定我在哪里犯了错误

下面附上我的代码

const Queue = require('bull');

const myFirstQueue = new Queue('my-first-queue', 
{
  redis: { 
      port: Config.redis.port, 
      host: Config.redis.host, 
      password: Config.redis.password 
  },
});



(async function ad() {
    const job = await myFirstQueue.add({
    foo: 'bar',
  });
})();

myFirstQueue.process(async (job, data) => {
  log.debug({ job, data }, 'Job data');
  let progress = 0;
  for (let i = 0; i < 10; i++) {
    await doSomething(data);
    progress += 10;
    job.progress(progress).catch(err => {
      log.debug({ err }, 'Job progress err');
    });
    log.debug({ progress …

根据这个包https://github.com/OptimalBits/bull是否有可能中止“等待队列”中的某个任务？我的用例如下：

我有一个 mongodb 集合“用户”和一个集合“友谊”，我在其中存储了两个用户的姓名和头像。所以我只需要一个查询来获取某个用户的好友列表。当用户更改他的头像时，我必须更新“friendship”集合中该用户内的所有文档。这是一个性能不重要的操作，因为我希望它在后台执行，并且一致性对于这个用例并不重要。但是当用户在短时间内多次更新他的头像时，我想取消所有引用旧任务（用于更新友谊集合），除了最新的。这与公牛可能吗？

提前致谢，我将不胜感激有关此的所有信息。

我想使用 node.js Bull处理预定的作业。基本上我有两个处理器可以处理两种类型的工作。有一个配置器可以配置将使用 cron 添加到公牛队列的作业。

调度器将在一个微服务中，每个处理器将是一个单独的微服务。所以我将拥有 3 个微服务。

我的问题是我对公牛使用了正确的模式吗？

索引.js

const Queue = require('bull');

const fetchQueue = new Queue('MyScheduler');
fetchQueue.add("fetcher", {name: "earthQuakeAlert"}, {repeat: {cron: '1-59/2 * * * *'}, removeOnComplete: true});
fetchQueue.add("fetcher", {name: "weatherAlert"}, {repeat: {cron: '3-59/3 * * * *'}, removeOnComplete: true});

处理器配置器.js

const Queue=require('bull');

const scheduler = new Queue("MyScheduler");
scheduler.process("processor", __dirname + "/alert-processor");

fetcher-configurator.js

const Queue=require('bull');

const scheduler = new Queue("MyScheduler");
scheduler.process("fetcher", __dirname+"/fetcher");

fetcher.js

const Queue = require('bull');
const moment = require('moment');

module.exports = function (job) { …

在 RPG 程序中是否有办法找出该程序正在运行的 JOBQ？我问这个问题是因为有一个可以调用或提交的程序，并且我有兴趣保存该程序运行的时间戳用户和 jobq 的日志。

提前致谢

我想知道是否有推荐的方法来检索https://github.com/yigit/android-priority-jobqueue中的活动作业列表

这样,如果我有持续的工作仍在等待,我可以让用户知道哪些工作.