opentelemetry instrumentation bullmq
1.0.0
Avertissement
Ce package est minimement maintenu et sera obsolète à l'avenir. Envisagez d'utiliser https://github.com/appsignal/opentelemetry-insrumentation-bullmq à la place
Ce module fournit une instrumentation de traçage automatique pour BullMQ.
Compatible avec l'OpenTelemetry JS API et SDK 1.0+ .
npm install --save @jenniferplusplus/opentelemetry-instrumentation-bullmq[1.90.1, 2.x, 3.x, 4.x, 5.x]Il est probable que l'instrumentation prendra en charge les versions antérieures de BullMQ, mais je ne l'ai pas testée.
L'instrumentation BullMQ OpenTelemetry permet à l'utilisateur de collecter automatiquement les données de trace des travaux et des travailleurs BullMQ et de les exporter vers le backend de choix.
Pour charger l'instrumentation, spécifiez-le dans la liste des instruments pour registerInstrumentations . Il n'y a actuellement aucune option de configuration.
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 ( ) ,
] ,
} ) ; | Nom | Méthode BullMQ | Description |
|---|---|---|
{QueueName.JobName} Queue.add | Queue.add | Un nouveau travail est ajouté à la file d'attente |
{QueueName} Queue.addBulk | Queue.addBulk | De nouveaux emplois sont ajoutés à la file d'attente en vrac |
{QueueName.FlowName} FlowProducer.add | FlowProducer.add | Un nouveau flux d'emploi est ajouté à une file d'attente |
FlowProducer.addBulk | FlowProducer.addBulk | De nouveaux flux d'emploi sont ajoutés aux files d'attente en vrac |
{QueueName.JobName} Job.addJob | Job.addJob | Chaque travail individuel ajouté à une file d'attente |
{WorkerName} Worker.run | Worker.run | Pendant qu'un travailleur accepte des emplois |
{QueueName.JobName} Worker.{WorkerName} #{attempt} | Worker.callProcessJob | Chaque exécution d'emploi par une fonction de processeur d'un travailleur |
Apache 2.0 - Voir la licence pour plus d'informations.
Je n'utilise plus BullMQ dans aucun de mes projets, et je n'ai donc aucune raison de mettre à jour cette bibliothèque. Je continuerai à mettre à jour pour prendre en charge les nouvelles versions de Node.js et des versions compatibles vers l'arrière de BullMQ. Je n'accepte pas de nouvelles fonctionnalités et je ne ferais probablement pas de mises à jour pour les changements de rupture de BullMQ. Je prévois de déprécier ce package lorsqu'il y a un successeur clair. Actuellement, l'implémentation d'AppSignals est la plus mature. L'API et la télémétrie émise sont très similaires à celle car elle a été fourchue de ce projet. Taskforce.sh développe également une solution de traçage de premier parti.
