Spring cloud sleuth添加标签

Question

我正在尝试使用spring cloud sleuth在我的kotlin应用程序中实现分布式跟踪。我正在把这些数据发送给数据狗。现在我可以跟踪日志了，但我想向span中添加一些额外的数据。假设我想添加关于用户的信息，并能够在datadog中看到它。span标签对它有好处吗？我正在将json格式的日志发送到datadog，但我不能在这里添加标记。（注入traceId和spanId）。登录配置：

        <encoder class="net.logstash.logback.encoder.LoggingEventCompositeJsonEncoder">
            <providers>
                <timestamp/>
                <version/>
                <message/>
                <loggerName/>
                <threadName/>
                <logLevel/>
                <logLevelValue/>
                <callerData/>
                <stackTrace/>
                <rootStackTraceElement/>
                <context/>
                <mdc/>
                <tags/>
                <logstashMarkers/>
                <arguments/>
            </providers>
        </encoder>

格拉德尔：

implementation("org.jetbrains.kotlin:kotlin-reflect")
implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8")
implementation("org.springframework.cloud:spring-cloud-starter-netflix-eureka-server")
implementation("org.springframework.cloud:spring-cloud-starter-vault-config")
implementation("org.springframework.cloud:spring-cloud-starter-sleuth")
implementation("org.springframework.boot:spring-boot-starter-actuator")
implementation("ch.qos.logback:logback-classic:1.2.3")
implementation("net.logstash.logback:logstash-logback-encoder:6.6")
implementation("org.zalando:logbook-spring-boot-starter:2.4.2")
developmentOnly("org.springframework.boot:spring-boot-devtools")
runtimeOnly("io.micrometer:micrometer-registry-datadog")
testImplementation("org.springframework.boot:spring-boot-starter-test")

加上我正在尝试的标签

@NewSpan
fun newSpanTest() {
    tracer.currentSpan()!!.tag("user", "123")
    log.info("other span")
    otherTestService.sameSpanTest()
}

日志示例：

{"@timestamp":"2021-03-09T21:04:46.953+01:00","@version":"1","message":"other span","logger_name":"com.microservices.text.rpg.servicediscovery.TestService","thread_name":"http-nio-8761-exec-3","level":"INFO","level_value":20000,"caller_class_name":"com.microservices.text.rpg.servicediscovery.TestService","caller_method_name":"newSpanTest","caller_file_name":"TestService.kt","caller_line_number":25,"traceId":"e61fd165d7c84776","spanId":"5e61f9b51b51619b"}

那个“用户”不应该被注入MDC，然后注入日志吗？

Answer 1

spring.sleuth.baggage。相关字段自动将行李值设置为Slf4j的MDC，因此您只需设置行李字段。

我想你使用现成的侦探（使用勇敢）：

1. 第一，熟悉标签、行李和它们的差异；你也可以在勇敢的文档中读到它们
2. 检查Brave的ScopeDecorator、Cor的ScopeDecorator和MDCScopeDecorator

spring.sleuth.baggage。相关字段属性自动将行李值设置为Slf4j的MDC，因此您只需设置行李字段。

此外，使用MDCScopeDecorator，您可以通过编程方式将baggage值设置为Slf4j的MDC，您可以在Sleuth文档中看到如何做到这一点：

// configuration
@Bean
BaggageField countryCodeField() {
    return BaggageField.create("country-code");
}

@Bean
ScopeDecorator mdcScopeDecorator() {
    return MDCScopeDecorator.newBuilder()
            .clear()
            .add(SingleCorrelationField.newBuilder(countryCodeField())
                    .flushOnUpdate()
                    .build())
            .build();
}

// service
@Autowired
BaggageField countryCodeField;

countryCodeField.updateValue("new-value");