opentelemetry instrumentation bullmq

警告

该软件包的维护最低，并将在将来被弃用。考虑使用https://github.com/appsignal/opentelemetry-instrumentation-bullmq

opentelemetry buldmq indo inode.js

该模块为BullMQ提供了自动跟踪仪器。

与OpenTelemetry JS API和SDK 1.0+兼容。

安装

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

支持版本

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

该仪器可能会支持较早版本的BullMQ，但我尚未对其进行测试。

用法

OpentElemetry BullMQ仪器允许用户自动从BullMQ工作和工人收集跟踪数据，并将其导出到选择的后端。

要加载仪器，请在仪器列表中将其指定为registerInstrumentations 。当前没有配置选项。

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

发出的跨度

姓名	BULLMQ方法	描述
{QueueName.JobName} Queue.add	Queue.add	队列添加了新工作
{QueueName} Queue.addBulk	Queue.addBulk	新工作批量添加到队列中
{QueueName.FlowName} FlowProducer.add	FlowProducer.add	队列添加了新的工作流程
FlowProducer.addBulk	FlowProducer.addBulk	新的工作流程批量添加到队列中
{QueueName.JobName} Job.addJob	Job.addJob	每个工作都添加到队列中
{WorkerName} Worker.run	Worker.run	工人正在接受工作
{QueueName.JobName} Worker.{WorkerName} #{attempt}	Worker.callProcessJob	每个工人的处理器功能执行的每个工作执行

有用的链接

• 有关OpenTelemetry的更多信息，请访问：https：//opentelemetry.io/
• 有关opentelemetry javascript的更多信息：https：//github.com/open-telemetry/opentelemetry-js
• 寻求有关此项目的帮助或反馈，请打开问题或提交公关

执照

Apache 2.0-有关更多信息，请参见许可证。

贡献

我不再在任何项目中使用BullMQ，因此我没有理由更新此库。我将继续更新以支持Node.js的新版本，以及BullMQ的向后兼容版本。我不接受新功能，并且可能不会为BullMQ的任何破坏变化做出更新。我计划在有明确的继任者时贬低此软件包。当前，AppSignals的实现是最成熟的。 API和发射的遥测与该项目的分配非常相似。 Tasksforce.SH还正在开发第一方追踪解决方案。