我对 NestJS 和 Bull MQ 有疑问,每当我尝试处理多个作业时,只会执行第一个作业,而不会执行其余作业。
我浏览电子邮件,然后开始像这样处理它们。只有第一个被添加到队列中,而不是其余的。
for (let i = 0; i < mails.length; i++) {
const mail = mails[i];
await this.metricsQueue.add(
'metricsImport',
{
date: mail.subject.split(';')[2],
locationId: Number(mail.subject.split(';')[1]),
sender: mail.sender,
},
{ jobId: mail.mailId },
);
}