无法对公牛队列进行速率限制

问题描述

为了管理流量并有效处理特定消息，/ 我们已经实施了限速牛市队列：- 但我们无法实现速率限制。 这是我的实现，但此队列中的速率限制不起作用

const createNewQueue = async({ queueName,queueOpts = {},defaultJobOpts = null,queueUrl = null }) =>{
try{
    console.log("createNewQueue fn called")
    if(defaultJobOpts){
        queueOpts.defaultJobOptions = defaultJobOpts
    }
    queueOpts['redis'] ={
      port:process.env.CS_REdis_PORT,host:process.env.CS_REdis_URL,password:process.env.CS_REdis_PASSWORD
    }
    queueUrl = queueUrl ? queueUrl : redisUrl
    const newQueue = new Queue(queueName,queueOpts )
    console.log("\n\n\n queue created ------\n",newQueue)
    Queues[queueName] = newQueue
    return newQueue
}
catch(err){
    handleAppError({err})
}

}

const inputQueue = {
queueName: 'inputQueue',processLeftJobs: true,processOptions: {
  concurrency: 1
},cleanQueue: true,cleanQueueEvents: [
  'completed'
],queueOpts:{
  limiter: {
    max: 1000,duration: 10000
  }
}

}

await createNewQueue(inputQueue)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）