- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我知道我们要使用上下文传播来获取创建为彼此子项的父 traceid 和跨度,但我的发布者使用的是 header (nats 而不是 http)
我的消息代理使用 header ,我在出站请求中将 traceid 和 spanid 设置为 header ,发送消息,然后订阅者应该能够创建一个新的跨度,将父 traceid 设置为来自要求。链接他们
我的出站请求如下所示:
msg := new(nats.Msg)
msg.Data = []byte("new request being sent!")
msg.Subject = subject
getTraceID := requestSpan.SpanContext().TraceID().String()
header := make(nats.Header)
msg.Header = header
header.Set("traceid", getTraceID)
getSpanID := requestSpan.SpanContext().SpanID().String(
header.Set("spanid", getSpanID)
msg.Header = header
reply, err := nc.RequestMsg(msg, time.Duration(5*time.Second))
这有效,在订阅者端我可以获得跟踪和跨度 ID 的 header 值
如何使用 traceid 在订阅者端构建上下文/跨度?
我相信我可以在 channel 内做这样的事情:
var traceID trace.TraceID
traceID, err = trace.TraceIDFromHex(request.TraceID)
if err != nil {
fmt.Println("error: ", err)
continue
}
var spanID trace.SpanID
spanID, err = trace.SpanIDFromHex(request.SpanID)
if err != nil {
fmt.Println("error: ", err)
continue
}
spanContext := trace.NewSpanContext(trace.SpanContextConfig{
TraceID: traceID,
SpanID: spanID,
TraceFlags: 01,
})
ctx := context.Background()
ctx = trace.ContextWithSpanContext(ctx, spanContext)
var requestInLoopSpan trace.Span
ctx2, requestInLoopSpan := otel.Tracer("requestInLoop").Start(ctx, "requestInLoopSpan")
requestInLoopSpan.AddEvent("processing....") // NOT WORKING
最佳答案
知道了!
顺便说一句,输入 NewRequest:
type NewRequest struct {
Requestid string `json: "requestid"`
TraceID string
SpanID string
}
您需要将构造 spanContext 的代码包装在一个函数中:
func constructNewSpanContext(request NewRequest) (spanContext trace.SpanContext, err error) {
var traceID trace.TraceID
traceID, err = trace.TraceIDFromHex(request.TraceID)
if err != nil {
fmt.Println("error: ", err)
return spanContext, err
}
var spanID trace.SpanID
spanID, err = trace.SpanIDFromHex(request.SpanID)
if err != nil {
fmt.Println("error: ", err)
return spanContext, err
}
var spanContextConfig trace.SpanContextConfig
spanContextConfig.TraceID = traceID
spanContextConfig.SpanID = spanID
spanContextConfig.TraceFlags = 01
spanContextConfig.Remote = false
spanContext = trace.NewSpanContext(spanContextConfig)
return spanContext, nil
}
然后你称之为传递包含跟踪和跨度 ID 的东西
然后使用函数返回的 spanContext 来丰富上下文:
spanContext, err := constructNewSpanContext(request)
if err != nil {
fmt.Println("ERROR: ", err)
}
fmt.Println("IS VALID? ", spanContext.IsValid()) // check if okay
requestContext := context.Background()
requestContext = trace.ContextWithSpanContext(requestContext, spanContext)
var requestInLoopSpan trace.Span
childContext, requestInLoopSpan := otel.Tracer("inboundmessage").Start(requestContext, "requestInLoopSpan")
requestInLoopSpan.AddEvent("processing....") // WORKING
关于go - 如何从字符串 traceid 创建 opentelemetry 跨度,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/70378025/
Spring 的 sleuth 添加到 MDC X-B3-SpanId 和 SpanId。 (TraceId 相同) {X-B3-SpanId=0000000000000001, X-B3-Trace
我们有一个遵循微服务架构的分布式应用程序。在我们的一项微服务中,我们遵循生产者-消费者模式。 生产者接收请求,将其保存到数据库,将请求推送到 BlockingQueue 并将响应发送回客户端。在单独线
我一直在尝试将跟踪 ID 添加到我的微服务日志中。我试过使用 sleuth 和 spring cloud,它正在工作。但我不想加载 spring cloud 只是为了将 trace id 添加到我的日
我尝试在我的微服务中添加分布式跟踪(在 Azure 中的 Kubernetes 下)。 我在父 pom.xml 中添加了依赖项: org.springframework.boot s
我正在使用 zipkin-go-opentracing , 这是 opentracing 的实现用于 zipkin 的 API。 出于(原因)我需要从跨度中获取 traceId。所以问题是:给定一个
我知道我们要使用上下文传播来获取创建为彼此子项的父 traceid 和跨度,但我的发布者使用的是 header (nats 而不是 http) 我的消息代理使用 header ,我在出站请求中将 tr
我正在使用 Sleuth,我想知道是否可以获取当前的 traceId? 我不需要添加任何回复或任何东西。我只想要在某些情况下提醒开发团队的电子邮件的 traceId。 最佳答案 前任 import b
我正在使用 grpc-java 并有 3 个服务,A、B 和 C。我调用服务 A,然后服务 A 调用 B 和 C。我在对 B 和 C 的调用中使用 Hystrix。C 依次产生另一个调用另一个服务的线
我已经开始学习 Sleuth,但我陷入了日志配置。 我有这个配置:
所以我正在使用 Jaeger 和 OpenTracing 来跟踪我的 Spring Boot 微服务之间的请求。我已经设置了所有必要的配置并添加了依赖项: io.opentracing.co
我正在维护几个用 ASP.NET 4.8(完整框架)和 ASP.NET Core 编写的应用程序。 .NET Core 实现 https://www.w3.org/TR/trace-context/这
我有一些 Spring 服务可以提交一些 AWS 批处理作业。这是一个简单的 spring 批处理作业,它调用外部服务的请求。我想通过将“org.springframework.cloud:sprin
有什么方法可以将具有不同跟踪 ID 的多个跟踪连接到单个跟踪中吗?就我而言,我有类似以下内容的内容,我想将其连接到单个跟踪中。 |--- UI Trace ----------------------
我需要生成带有跟踪 ID 的日志。目前我们正在使用winston 进行日志记录 我使用 winston 容器如下 var fs = require('fs'); var os = require('o
使用 MassTransit.RabbitMQ v5.3.2 和 OpenTracing.Contrib.NetCore v0.5.0。 我可以使用 MassTransit 向 RabbitMQ 发布
我正在研究多个微服务架构,其中入口点来自 Kafka。例如,假设我们有三个微服务micro1、micro2和micro3,micro1中的请求来自kafka消息队列,并通过Rest客户端进一步与mic
我想跟踪到达我的网络服务并发送 sns 通知的请求,该通知将触发 aws lambda 函数。在我的 lambda 函数中创建具有相同跟踪 ID 的新跨度的任何方法。 最佳答案 最好的方法是使用像 S
我需要将具有现有 ID 的 traceId(我们已经从主要来源应用程序创建了某种关联 ID)设置到 brave tracer 中。 我不想使用 Spring Sleuth/brave 创建的一个,因为
我有一个现有的 Spring boot (2.2.0) 应用程序,并尝试集成 Spring cloud sleuth 以获取自动跟踪和跨度 ID。 logback文件如下-
我希望我的服务使用者将 TraceId 作为 header 参数传递,名称为 X-B3-TraceId 和有效的 128 位十六进制字符串,该字符串将在进一步的路径中传播,并且服务实际上会将相同的 S
我是一名优秀的程序员,十分优秀!