BullMQ NestJS 外部进程配置

Question

我正在尝试配置外部流程，因为我的工作停滞不前：

    BullModule.registerQueue({
      name: 'compute',
      processors: [
        {
          callback: compute,
          concurrency: 2,
        },
      ],
    }),

我尝试按照此处所示设置并发，但它不起作用。由于它是外部进程，因此我无法使用

@Processor

装饰器。

我的作业被报告为失败（即使它们成功结束），因为我收到此错误：

错误：缺少作业 84 的锁失败

在线阅读后，似乎我可以增加

lockDuration

参数来避免这种情况，但同样，我不知道在哪里设置。

你能帮忙吗？谢谢！！

Answer 1

如果要设置lockDuration，请在创建新队列时设置 这是下面要设置的代码：

export const bulkDiscountQueue = new Queue('bulk-discount-queue', {
  redis,
  settings: { lockDuration: 5 * 60 }, //5 mins
});