opentelemetry instrumentation bullmq

Aviso

Este pacote é minimamente mantido e será preterido no futuro. Considere usar https://github.com/appsignal/opentelemetry-instrumation-bullmq em vez

Instrumentação de Bullmq de Opentelemetria para Node.js

Este módulo fornece instrumentação automática de rastreamento para Bullmq.

Compatível com a API Opentelemetria JS e SDK 1.0+ .

Instalação

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

Versões suportadas

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

É provável que a instrumentação suportasse versões anteriores do Bullmq, mas eu não o testei.

Uso

A instrumentação de Bullmq da OpenElemetria permite que o usuário colete automaticamente dados de rastreamento de trabalhos e trabalhadores da Bullmq e os exportam para o back -end de escolha.

Para carregar a instrumentação, especifique -o na lista de instrumentações para registerInstrumentations . Atualmente, não há opção de configuração.

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

Vãos emitidos

Nome	Método Bullmq	Descrição
{QueueName.JobName} Queue.add	Queue.add	Um novo trabalho é adicionado à fila
{QueueName} Queue.addBulk	Queue.addBulk	Novos empregos são adicionados à fila a granel
{QueueName.FlowName} FlowProducer.add	FlowProducer.add	Um novo fluxo de emprego é adicionado a uma fila
FlowProducer.addBulk	FlowProducer.addBulk	Novos fluxos de emprego são adicionados às filas a granel
{QueueName.JobName} Job.addJob	Job.addJob	Cada trabalho individual adicionado a uma fila
{WorkerName} Worker.run	Worker.run	Enquanto um trabalhador está aceitando empregos
{QueueName.JobName} Worker.{WorkerName} #{attempt}	Worker.callProcessJob	Cada execução de emprego pela função de processador de um trabalhador

Links úteis

• Para mais informações sobre o Opentelemetria, visite: https://opentelemetry.io/
• Para mais informações sobre o Opentelemetria JavaScript: https://github.com/open-telemetria/opentelemetry-js
• Para obter ajuda ou feedback sobre este projeto, abra um problema ou envie um PR

Licença

Apache 2.0 - Consulte Licença para obter mais informações.

Contribuindo

Não uso mais o Bullmq em nenhum dos meus projetos e, portanto, não tenho motivos para atualizar esta biblioteca. Continuarei atualizando para oferecer suporte a novas versões do Node.js e versões compatíveis com o Bullmq. Não estou aceitando novos recursos e provavelmente não fizeria atualizações para que nenhuma mudança no Bullmq. Planejo depreciar este pacote quando houver um sucessor claro. Atualmente, a implementação do AppSignals é a mais madura. A API e a telemetria emitida são muito semelhantes a esta, pois foi bifurcada neste projeto. Taskforce.sh também está desenvolvendo uma solução de rastreamento de primeira parte.