opentelemetry instrumentation bullmq

Warnung

Dieses Paket ist minimal gewartet und wird in Zukunft veraltet sein. Erwägen Sie stattdessen https://github.com/appsignal/opentelemetry-instrumentation-bullmq

Opentelemetry Bullmq Instrumentierung für node.js

Dieses Modul bietet automatische Verfolgungsinstrumente für Bullmq.

Kompatibel mit Opentelemetry JS API und SDK 1.0+ .

Installation

npm install --save @jenniferplusplus/opentelemetry-instrumentation-bullmq

Unterstützte Versionen

• [1.90.1, 2.x, 3.x, 4.x, 5.x]

Es ist wahrscheinlich, dass die Instrumentierung frühere Versionen von Bullmq unterstützen würde, aber ich habe sie nicht getestet.

Verwendung

OpenTelemetry Bullmq Instrumentation ermöglicht es dem Benutzer, Trace -Daten von Bullmq -Jobs und Arbeitnehmern automatisch zu sammeln und sie in den Backend der Wahl zu exportieren.

Um die Instrumentierung zu laden, geben Sie diese in der Liste der Instrumente in registerInstrumentations an. Derzeit gibt es keine Konfigurationsoption.

 const { NodeTracerProvider } = require ( '@opentelemetry/sdk-trace-node' ) ;
const { registerInstrumentations } = require ( '@opentelemetry/instrumentation' ) ;
const { BullMQInstrumentation } = require ( '@jenniferplusplus/opentelemetry-instrumentation-bullmq' ) ;

const provider = new NodeTracerProvider ( ) ;
provider . register ( ) ;

registerInstrumentations ( {
  instrumentations : [
    new BullMQInstrumentation ( ) ,
  ] ,
} ) ; 

Emittierte Spannweiten

Name	Bullmq -Methode	Beschreibung
{QueueName.JobName} Queue.add	Queue.add	Der Warteschlange wird ein neuer Job hinzugefügt
{QueueName} Queue.addBulk	Queue.addBulk	Neue Jobs werden in die Warteschlange in loser Schüttung hinzugefügt
{QueueName.FlowName} FlowProducer.add	FlowProducer.add	In einer Warteschlange wird ein neuer Jobfluss hinzugefügt
FlowProducer.addBulk	FlowProducer.addBulk	Neue Jobströme werden in die Warteschlangen in loser Schüttung hinzugefügt
{QueueName.JobName} Job.addJob	Job.addJob	Jeder einzelne Job fügte einer Warteschlange hinzu
{WorkerName} Worker.run	Worker.run	Während ein Arbeiter Jobs annimmt
{QueueName.JobName} Worker.{WorkerName} #{attempt}	Worker.callProcessJob	Jede Arbeitsplatzausführung durch die Prozessorfunktion eines Arbeiters

Nützliche Links

• Weitere Informationen zur Opentelemetrie finden Sie unter: https://opentelemetry.io/
• Weitere Informationen zu Opentelemetry JavaScript: https://github.com/open-telemetry/opentelemetry-js
• Für Hilfe oder Feedback zu diesem Projekt eröffnen Sie ein Problem oder senden Sie eine PR ein

Lizenz

Apache 2.0 - Weitere Informationen finden Sie unter Lizenz.

Beitragen

Ich verwende Bullmq in keinem meiner Projekte mehr und habe daher keinen Grund, diese Bibliothek zu aktualisieren. Ich werde weiterhin aktualisieren, um neue Versionen von Node.js und rückwärtskompatible Versionen von Bullmq zu unterstützen. Ich akzeptiere keine neuen Funktionen und würde wahrscheinlich keine Updates für Breaking -Änderungen in Bullmq vornehmen. Ich habe vor, dieses Paket abzubauen, wenn es einen klaren Nachfolger gibt. Derzeit ist die Implementierung von AppSignals die reifer. Die API und die emittierte Telemetrie sind diesem sehr ähnlich, da sie aus diesem Projekt gezogen wurde. Taskforce.sh entwickelt auch eine Erstanbieter-Verfolgungslösung.