我试图找到一种方法来传播两个服务之间的上下文通信通过rabbitmq在opentelemetry中。有一篇文章做类似的在Go article link中,但无法实现它在节点。
我正在考虑两种方法
1.在通过代理发布的消息的头中传递上下文。或者
1.基于traceId和spanId创建一个子span。answer link在Go语言中有一个答案,但是找不到创建新span的方法。
是否有任何代码参考可用于执行上述任何操作?
我试图找到一种方法来传播两个服务之间的上下文通信通过rabbitmq在opentelemetry中。有一篇文章做类似的在Go article link中,但无法实现它在节点。
我正在考虑两种方法
1.在通过代理发布的消息的头中传递上下文。或者
1.基于traceId和spanId创建一个子span。answer link在Go语言中有一个答案,但是找不到创建新span的方法。
是否有任何代码参考可用于执行上述任何操作?
1条答案
按热度按时间0g0grzrc1#
Opentelemetry节点已经有了amqp库的插件,它已经为你做了工作,即注入/提取上下文https://github.com/open-telemetry/opentelemetry-js-contrib/tree/main/plugins/node/instrumentation-amqplib。