[Support] bullmq中wokrer的使用

[RomenMark]

Describe the problem（描述问题）

@Processor('SendDataToDZPT', {}, {
  limiter: {
    max: 1,
    duration: 1000
  }
}, {})
export class SendDataToDZPTProcessor implements IProcessor {
  @Inject()
  environmentService: MidwayEnvironmentService;

  @InjectClient(HttpServiceFactory, 'DZPTAxios')
  DZPTAxios: HttpService;

  @Inject()
  ctx: Context

  async execute(data: any) {

    const res = await this.DZPTAxios.post('/api/devices/datapoints?type=2', data, {
      headers: {
        'Content-Type': 'application/json',
      },
    });


    if (res.status === 429) {
      await worker.rateLimit(duration);
      throw Worker.RateLimitError();
    }


  }

}

如何使用在Processor中使用Worker
实现类似bullmq官方示例

import { Worker } from 'bullmq';

const worker = new Worker(
  'myQueue',
  async () => {
    const [isRateLimited, duration] = await doExternalCall();
    if (isRateLimited) {
      await worker.rateLimit(duration);
      // Do not forget to throw this special exception,
      // since we must differentiate this case from a failure
      // in order to move the job to wait again.
      throw Worker.RateLimitError();
    }
  },
  {
    connection,
    limiter: {
      max: 1,
      duration: 500,
    },
  },
);

Midway Versions（Midway 版本）

✓ @midwayjs/faas-typings(not installed)
✓ @midwayjs/fc-starter(not installed)
✓ @midwayjs/serverless-http-parser(not installed)
✓ @midwayjs/async-hooks-context-manager(not installed)
✓ @midwayjs/axios(3.20.11)
✓ @midwayjs/bootstrap(3.20.11)
✓ @midwayjs/bull(not installed)
✓ @midwayjs/bull-board(3.20.11)
✓ @midwayjs/bullmq(3.20.11)
✓ @midwayjs/busboy(3.20.13)
✓ @midwayjs/cache-manager(3.20.11)
✓ @midwayjs/captcha(not installed)
✓ @midwayjs/casbin(not installed)
✓ @midwayjs/casbin-redis-adapter(not installed)
✓ @midwayjs/casbin-typeorm-adapter(not installed)
✓ @midwayjs/code-dye(not installed)
✓ @midwayjs/consul(not installed)
✓ @midwayjs/core(3.20.11)
✓ @midwayjs/cos(not installed)
✓ @midwayjs/cron(3.20.11)
✓ @midwayjs/cross-domain(not installed)
✓ @midwayjs/decorator(not installed)
✓ @midwayjs/etcd(not installed)
✓ @midwayjs/express-session(not installed)
✓ @midwayjs/faas(not installed)
✓ @midwayjs/grpc(not installed)
✓ @midwayjs/http-proxy(not installed)
✓ @midwayjs/i18n(not installed)
✓ @midwayjs/info(3.20.11)
✓ @midwayjs/jwt(3.20.11)
✓ @midwayjs/kafka(3.20.11)
✓ @midwayjs/leoric(not installed)
✓ @midwayjs/mikro(not installed)
✓ @midwayjs/mock(3.20.11)
✓ @midwayjs/mongoose(not installed)
✓ @midwayjs/mqtt(3.20.11)
✓ @midwayjs/oss(not installed)
✓ @midwayjs/otel(not installed)
✓ @midwayjs/passport(not installed)
✓ @midwayjs/process-agent(not installed)
✓ @midwayjs/prometheus(3.20.13)
✓ @midwayjs/prometheus-socket-io(not installed)
✓ @midwayjs/rabbitmq(not installed)
✓ @midwayjs/redis(3.20.11)
✓ @midwayjs/security(not installed)
✓ @midwayjs/sequelize(not installed)
✓ @midwayjs/session(not installed)
✓ @midwayjs/socketio(not installed)
✓ @midwayjs/static-file(not installed)
✓ @midwayjs/swagger(3.20.11)
✓ @midwayjs/tablestore(not installed)
✓ @midwayjs/tags(not installed)
✓ @midwayjs/tenant(not installed)
✓ @midwayjs/typegoose(not installed)
✓ @midwayjs/typeorm(3.20.11)
✓ @midwayjs/upload(not installed)
✓ @midwayjs/validate(3.20.11)
✓ @midwayjs/version(not installed)
✓ @midwayjs/view(not installed)
✓ @midwayjs/view-ejs(not installed)
✓ @midwayjs/view-nunjucks(not installed)
✓ @midwayjs/web(not installed)
✓ @midwayjs/express(not installed)
✓ @midwayjs/koa(3.20.11)
✓ @midwayjs/ws(not installed)

---

[RomenMark]

import {IProcessor, Processor, Context, BullMQ, InjectQueue,} from "@midwayjs/bullmq";
import {Inject, InjectClient, MidwayEnvironmentService} from "@midwayjs/core";
import {HttpService, HttpServiceFactory} from "@midwayjs/axios";

@Processor('SendDataToDZPT', {}, {
  limiter: {
    max: 1,
    duration: 1000
  }
}, {})
export class SendDataToDZPTProcessor implements IProcessor {
  @Inject()
  environmentService: MidwayEnvironmentService;

  @InjectClient(HttpServiceFactory, 'DZPTAxios')
  DZPTAxios: HttpService;

  @Inject()
  ctx: Context

  @Inject('dayjs')
  dayjsTool;

  @InjectQueue('SendDataToDZPT')
  queue: BullMQ.Queue;

  async execute(data: any) {
    const {RateLimitError} = BullMQ

    const res = await this.DZPTAxios.post('/api/devices/datapoints?type=2', data, {
      headers: {
        'Content-Type': 'application/json',
      },
    });

    if (res.status === 429) {
        /**
         * Overrides the rate limit to be active for the next jobs.
         * @deprecated This method is deprecated and will be removed in v6. Use queue.rateLimit method instead.
         * @param expireTimeMs - expire time in ms of this rate limit.
         */
       // rateLimit(expireTimeMs: number): Promise<void>;


      await this.queue.rateLimit(10 * 1000) // worker的rateLimit于v6废除，故用queue
      throw new RateLimitError();
    }
    
  }

}

已找到解决方案，希望官方加入bullmq的文档示例中。