BullMQ

BullMQ est une bibliothèque de file d’attente de jobs Node.js basée sur Redis. L’intégration AppSignal pour Node.js pour BullMQ instrumente la mise en file d’attente et le traitement dans votre application.

Installation

Pour les versions 5 et antérieures de BullMQ, le package BullMQ est instrumenté automatiquement par le package AppSignal pour Node.js. Pour la version 6 de BullMQ, consultez les instructions d’installation et de configuration de la section suivante. Si vous exécutez vos workers en tant que processus séparés, assurez-vous d’utiliser également node --require appsignal.cjs ... lors du démarrage des processus workers, afin qu’AppSignal puisse instrumenter le traitement des jobs des workers.

Installation et configuration de BullMQ 6

La version 6 de BullMQ n’est pas instrumentée automatiquement. Elle transmet ses données via la télémétrie propre à BullMQ, ce qui nécessite l’installation du package bullmq-otel :

npm install bullmq-otel

Passez une instance de BullMQOtel en tant qu’option telemetry à chaque queue et à chaque worker :

const { Queue, Worker } = require("bullmq");
const { BullMQOtel } = require("bullmq-otel");

const telemetry = new BullMQOtel();

const queue = new Queue("my-queue", { connection, telemetry });
const worker = new Worker("my-queue", processor, { connection, telemetry });

Ne définissez pas l’option tracerName lors de l’initialisation de BullMQOtel. AppSignal identifie ces spans par leur portée d’instrumentation, qui doit être bullmq. Pour en savoir plus, consultez la documentation de télémétrie de BullMQ.

Fonctionnalités

Lorsque vous utilisez l’intégration BullMQ, AppSignal créera une trace de performance pour chaque job traité par un worker. Lorsqu’un job est mis en file d’attente dans un contexte instrumenté, comme une requête web ou un job en arrière-plan, AppSignal affichera un événement dans la chronologie d’événements de la trace de performance représentant la mise en file d’attente du job.

SDK & télémétrie

SDK de langage

Outils de télémétrie

Installation

Installation et configuration de BullMQ 6

Fonctionnalités

​Installation

​Installation et configuration de BullMQ 6

​Fonctionnalités

Installation

Installation et configuration de BullMQ 6

Fonctionnalités