opentelemetry instrumentation bullmq

Advertencia

Este paquete se mantiene mínimamente y estará en desuso en el futuro. Considere usar https://github.com/appsignal/opentelemetry-instrumentation-bullmq en su lugar

Instrumentación BullMQ OPENTELEMETRY para Node.js

Este módulo proporciona instrumentación de rastreo automático para Bullmq.

Compatible con OPENTELEMETRY JS API y SDK 1.0+ .

Instalación

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

Versiones compatibles

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

Es probable que la instrumentación admita versiones anteriores de Bullmq, pero no la he probado.

Uso

La instrumentación BullMQ OpenTelemetry permite al usuario recopilar automáticamente datos de trazas de trabajos y trabajadores de Bullmq y exportarlos al backend de elección.

Para cargar la instrumentación, especifíquela en la lista de instrumentos para registerInstrumentations . Actualmente no hay opción de configuración.

 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 ( ) ,
  ] ,
} ) ; 

Tramos emitidos

Nombre	Método BullMQ	Descripción
{QueueName.JobName} Queue.add	Queue.add	Se agrega un nuevo trabajo a la cola
{QueueName} Queue.addBulk	Queue.addBulk	Se agregan nuevos trabajos a la cola a granel
{QueueName.FlowName} FlowProducer.add	FlowProducer.add	Se agrega un nuevo flujo de trabajo a una cola
FlowProducer.addBulk	FlowProducer.addBulk	Se agregan nuevos flujos de trabajo a las colas a granel
{QueueName.JobName} Job.addJob	Job.addJob	Cada trabajo individual agregado a una cola
{WorkerName} Worker.run	Worker.run	Mientras un trabajador acepta trabajos
{QueueName.JobName} Worker.{WorkerName} #{attempt}	Worker.callProcessJob	Cada ejecución de trabajo por la función de procesador de un trabajador

Enlaces útiles

• Para obtener más información sobre OpenLemeterry, visite: https://opentelemetry.io/
• Para obtener más información sobre OpenTelemetry JavaScript: https://github.com/open-telemetry/opentelemetry-js
• Para obtener ayuda o comentarios sobre este proyecto, abra un problema o envíe un PR

Licencia

Apache 2.0 - Consulte la licencia para obtener más información.

Que contribuye

Ya no uso BullMQ en ninguno de mis proyectos, por lo que no tengo ninguna causa para actualizar esta biblioteca. Continuaré actualizando para admitir nuevas versiones de Node.js y versiones compatibles con retroceso de BullMQ. No estoy aceptando nuevas funciones, y es probable que no realice actualizaciones para ningún cambio de ruptura en Bullmq. Planeo desaprobar este paquete cuando hay un sucesor claro. Actualmente, la implementación de AppSignals es la más madura. La API y la telemetría emitida son muy similares a esta, ya que fue bifurcada de este proyecto. Taskorce.sh también está desarrollando una solución de rastreo de primera parte.