opentelemetry instrumentation bullmq

Peringatan

Paket ini dipelihara secara minimal, dan akan sudah usang di masa depan. Pertimbangkan untuk menggunakan https://github.com/appsignal/opentelemetry-instrumentation-bullmq sebagai gantinya

OpenTelemetry Bullmq Instrumentation untuk Node.js

Modul ini menyediakan instrumentasi penelusuran otomatis untuk Bullmq.

Kompatibel dengan OpenTelemetry JS API dan SDK 1.0+ .

Instalasi

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

Versi yang didukung

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

Kemungkinan instrumentasi akan mendukung versi Bullmq sebelumnya, tetapi saya belum mengujinya.

Penggunaan

Instrumentasi OpenTelemetry Bullmq memungkinkan pengguna untuk secara otomatis mengumpulkan data jejak dari pekerjaan dan pekerja Bullmq dan mengekspornya ke backend pilihan.

Untuk memuat instrumentasi, tentukan dalam daftar instrumentasi untuk registerInstrumentations . Saat ini tidak ada opsi konfigurasi.

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

Rentang yang dipancarkan

Nama	Metode Bullmq	Keterangan
{QueueName.JobName} Queue.add	Queue.add	Pekerjaan baru ditambahkan ke antrian
{QueueName} Queue.addBulk	Queue.addBulk	Pekerjaan baru ditambahkan ke antrian dalam jumlah besar
{QueueName.FlowName} FlowProducer.add	FlowProducer.add	Aliran pekerjaan baru ditambahkan ke antrian
FlowProducer.addBulk	FlowProducer.addBulk	Aliran pekerjaan baru ditambahkan ke antrian dalam jumlah besar
{QueueName.JobName} Job.addJob	Job.addJob	Setiap pekerjaan individu ditambahkan ke antrian
{WorkerName} Worker.run	Worker.run	Saat seorang pekerja menerima pekerjaan
{QueueName.JobName} Worker.{WorkerName} #{attempt}	Worker.callProcessJob	Setiap pelaksanaan pekerjaan dengan fungsi prosesor pekerja

Tautan yang berguna

• Untuk informasi lebih lanjut tentang OpenTelemetry, kunjungi: https://opentelemetry.io/
• Untuk informasi lebih lanjut tentang OpenTelemetry JavaScript: https://github.com/open-telemetry/opentelemetry-js
• Untuk bantuan atau umpan balik pada proyek ini, buka masalah atau kirimkan PR

Lisensi

Apache 2.0 - Lihat lisensi untuk informasi lebih lanjut.

Berkontribusi

Saya tidak lagi menggunakan Bullmq di salah satu proyek saya, jadi saya tidak punya alasan untuk memperbarui perpustakaan ini. Saya akan terus memperbarui untuk mendukung versi baru Node.js, dan versi Bullmq yang kompatibel dengan kemunduran. Saya tidak menerima fitur baru, dan saya mungkin tidak akan membuat pembaruan untuk perubahan besar di Bullmq. Saya berencana untuk mencela paket ini ketika ada penerus yang jelas. Saat ini, implementasi AppSignals adalah yang paling matang. API dan telemetri yang dipancarkan sangat mirip dengan yang ini karena bercabang dari proyek ini. Task force.sh juga mengembangkan solusi penelusuran pihak pertama.