发射器传送范围

在 Go 中使用 Jaeger 时，可以通过调整配置来优化数据传输范围。通过设置 Sampler 和 Reporter 配置，可以控制向 Jaeger 后端发送数据的采样率和目标地址。例如，通过将 Sampler 的 Type 设置为 "const"，可以指定恒定的采样率，确保所有跨度都发送到 Jaeger。此外，通过指定 LocalAgentHostPort，可以指定 Jaeger 代理的 IP 地址和端口，从而确定跨度发送的目标。

我正在尝试在 go 中与 jaeger 一起使用仪器。

我正在像这样使用 docker 运行 jaeger 后端（如 https://www.jaegertracing.io/docs/1.15/getting-started/ 中所述）：

docker run -d --name jaeger \
  -e collector_zipkin_http_port=9411 \
  -p 5775:5775/udp \
  -p 6831:6831/udp \
  -p 6832:6832/udp \
  -p 5778:5778 \
  -p 16686:16686 \
  -p 14268:14268 \
  -p 9411:9411 \
  jaegertracing/all-in-one:1.15

但是，运行以下 go 代码后，我无法在 http://localhost:16686 的 jaeger ui 中看到跨度，并且我不确定这段代码有什么问题？我从一段类似的 python 代码开始，它能够在 jaeger ui 上发布跨度。

package main

import (
    "fmt"
    "io"

    opentracing "github.com/opentracing/opentracing-go"
    jaeger "github.com/uber/jaeger-client-go"
    jaegercfg "github.com/uber/jaeger-client-go/config"
)

func initJaeger(service string) (opentracing.Tracer, io.Closer) {
    agentIP := "localhost"
    agentPort := "5775"
    so := jaeger.SamplerOptionsFactory{}
    logger := jaeger.StdLogger
    logger.Infof("Sending Traces to %s %s", agentIP, agentPort)
    cfg := &jaegercfg.Configuration{
        Sampler: &jaegercfg.SamplerConfig{
            Type:    "const",
            Param:   1,
            Options: []jaeger.SamplerOption{so.Logger(logger)},
        },
        ServiceName: service,
        Reporter: &jaegercfg.ReporterConfig{
            LogSpans:           true,
            LocalAgentHostPort: agentIP + ":" + agentPort,
        },
    }
    tracer, closer, err := cfg.NewTracer(jaegercfg.Logger(logger))
    if err != nil {
        panic(fmt.Sprintf("ERROR: cannot init Jaeger: %v\n", err))
    }

    opentracing.SetGlobalTracer(tracer)
    return opentracing.GlobalTracer(), closer
}

func main() {

    tracer, closer := initJaeger("foo-go-service")

    span := tracer.StartSpan("GoTestSpan")
    var myMap = make(map[string]interface{})
    myMap["foo"] = 42
    myMap["bar"] = "42"
    span.LogKV(myMap)

    childSpanRef := opentracing.ChildOf(span.Context())
    childSpan := tracer.StartSpan("GoChildSpan", childSpanRef)
    var myMap2 = make(map[string]interface{})
    myMap2["foo2"] = 42
    myMap2["bar2"] = "42"
    childSpan.LogKV(myMap2)

    closer.Close()
}

我正在此处挖掘文档 https://godoc.org/github.com/uber/jaeger-client-go 以及此处的开放跟踪项目的文档 https://godoc.org/github.com/ opentracing/opentracing-go，但我对术语和库函数/方法有点困惑。

• 我想将“通用”事件发布到 jaeger 后端并在 jaeger ui 中查看这些事件。
• 我还想使用某种请求结构的自动包装器来发布“http 请求”事件，但目前即使是简单/通用事件也很好。

解决方案

我能够发布一些跨度，以便我可以在 http://localhost:16686 上看到它们

• 我们应该在 span 上使用 setoperationname ，以便我们可以在 ui 上使用人类可读的名称来识别它
• 我们还应该推迟 span.finish() 调用，这似乎就是我在 ui 上看不到任何内容的原因

这是更新后的主要功能：

func main() {

    tracer, closer := initJaeger("foo-go-service")
    defer closer.Close()

    span := tracer.StartSpan("GoTestSpan")
    defer span.Finish()
    span.SetOperationName("opNameGoTestSpan")
    var myMap = make(map[string]interface{})
    myMap["foo"] = 42
    myMap["bar"] = "42"
    span.LogKV(myMap)

    // time.Sleep(2 * time.Second)

    childSpanRef := opentracing.ChildOf(span.Context())
    childSpan := tracer.StartSpan("GoChildSpan", childSpanRef)
    defer childSpan.Finish()
    childSpan.SetOperationName("opNameGoChildSpan")
    var myMap2 = make(map[string]interface{})
    myMap2["foo2"] = 42
    myMap2["bar2"] = "42"
    childSpan.LogKV(myMap2)
}

理论要掌握，实操不能落！以上关于《发射器传送范围》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！