mikro-orm - 与 BullMQ 等后台工作人员一起使用时，MikroORM 是否需要 RequestContext？

Question

我正在将 MikroORM 与BullMQ工作人员一起使用。当 MikroORM 与 Express 应用程序一起使用时，它需要一个RequestContext来维护每个请求的唯一身份映射。我怀疑在使用同一个 BullMQ 工作人员处理多个作业时也需要这样做。

有没有其他人成功地结合了这两个库？工人开始新工作时是否可以自动分叉实体管理器？

Answer 1

您可以@UseRequestContext()在这种情况下使用装饰器。它基本上就像在添加上下文的中间件之后执行该方法一样。请注意，要使用它，this.orm需要是MikroORM实例。

@Injectable()
export class MyService {

  constructor(private readonly orm: MikroORM) { }

  @UseRequestContext()
  async doSomething() {
    // this will be executed in a separate context
  }

}

https://mikro-orm.io/docs/usage-with-nestjs/#request-scoped-handlers-in-queues

（这部分文档是关于nestjs的，但使用相同的解决方案是同样的问题）

或者，您可以RequestContext.createAsync()明确使用：

await RequestContext.createAsync(orm.em, async () => {
  // orm.em here will use the contextual fork created just for this handler
});