Eine Warteschlange erstellen

Wenn Sie eine Warteschlange erstellen, geben Sie die maxInflight und die msgPerSecond Parameter. Wenn Sie diese Parameter zusammen verwenden, können Sie die Entlassungsrate steuern.

Methode Unterschrift

createQueue(queueName: string, callback: string, options: ICreateQueueOptions)

Typen

CreateQueueOptions:

  • maxInflight(Number) Die Anzahl der Aufgaben, die Sie gleichzeitig ausführen können.
  • msgPerSecond(Number) Die Anzahl der Aufgaben, die pro Sekunde an Ihren Callback-Endpunkt gesendet werden.
  • active: (Boolesch) true wird die Warteschlange so eingestellt, dass sie mit der Bearbeitung von Aufträgen beginnt, sobald sie hinzugefügt werden.

Erstellen einer Warteschlange

await queue.createQueue('queue', 'execute', { 
    maxInflight: 10, 
    msgPerSecond: 100, 
    active: true
});