网站建设的行业新闻,长春小学网站建设,黄骅招聘网最新招工信息,平面设计机构培训今日已办
根据导师代码评审的 comment 改进
修改命名 otelclient.otelExporterOtlpEndpoint to otelclient.endpoint禁用 TLS 加密#xff0c;移除 otelclient.insecureMode避免命名缩写影响代码的阅读理解把两个函数#xff08;createTraceExp和createTraceProvider#…今日已办
根据导师代码评审的 comment 改进
修改命名 otelclient.otelExporterOtlpEndpoint to otelclient.endpoint禁用 TLS 加密移除 otelclient.insecureMode避免命名缩写影响代码的阅读理解把两个函数createTraceExp和createTraceProvider合并移除没有太大意义的封装handleErr将 otel 初始化逻辑放到 consume 子命令中进行还原 README.md 的内容经过组员 郑兆隆 对 Log 逻辑的修改Log 可以在 docker容器内部 和 SigNoz Web 都生效
调研 整个链路都要带上backend_id调研是否有让trace带attribute的方法而不是每个span都手动加上 Trace 下的所有 span
在使用 OpenTelemetry SDK 进行分布式追踪时可以通过在 span 上设置属性attribute来添加自定义信息以便更好地理解和调试应用程序的行为。要让一个 trace 下的所有 span 都带上 attribute可以使用 OpenTelemetry SDK 提供的 Span Processor。
下面是一个示例代码展示了如何使用 Span Processor 将指定的 attribute 添加到 trace 下的所有 span 中
package mainimport (contextgo.opentelemetry.io/otelgo.opentelemetry.io/otel/attributego.opentelemetry.io/otel/exporters/stdoutsdktrace go.opentelemetry.io/otel/sdk/trace
)func main() {// 创建一个 stdout exporter将 span 输出到控制台exporter, err : stdout.NewExporter(stdout.WithPrettyPrint())if err ! nil {panic(err)}// 创建一个 trace provider使用 stdout exporter 输出 spanprovider : sdktrace.NewTracerProvider(sdktrace.WithBatcher(exporter))// 设置全局 trace providerotel.SetTracerProvider(provider)// 创建一个 span processor将指定的 attribute 添加到所有 span 中processor : sdktrace.NewSimpleSpanProcessor(func(span sdktrace.ReadOnlySpan) {span.SetAttributes(attribute.String(my_attribute, my_value))})// 将 span processor 添加到 trace provider 中provider.RegisterSpanProcessor(processor)// 创建一个新的 spantracer : otel.Tracer(example)ctx, span : tracer.Start(context.Background(), my_span)defer span.End()// 在 span 上设置其他 attributespan.SetAttributes(attribute.String(another_attribute, another_value))// 执行其他操作...
}在上面的示例代码中使用 sdktrace.NewSimpleSpanProcessor 创建了一个简单的 Span Processor该处理器会调用指定的函数并将当前 span 作为参数传递给该函数。在该函数中可以使用 span.SetAttributes 方法添加需要的 attribute。然后将该 Span Processor 添加到 trace provider 中即可让所有的 span 都带上该 attribute。
需要注意的是Span Processor 对所有 span 生效因此要谨慎使用以避免影响性能和数据质量。如果只想让某些 span 带上 attribute可以在创建 span 时手动设置。
特点 Trace 下的所有 span
如果只想在一个特定的 trace 的所有 span 中加上某个 attribute可以使用 OpenTelemetry SDK 提供的 Span Processor并且在创建 Span Processor 时指定一个 filter 函数该函数可以根据 span 的 trace ID 或其他属性来判断是否需要对该 span 添加指定的 attribute。
下面是一个示例代码展示了如何使用 Span Processor 和 filter 函数来只在特定 trace 的所有 span 中添加指定的 attribute
package mainimport (contextgo.opentelemetry.io/otelgo.opentelemetry.io/otel/attributego.opentelemetry.io/otel/exporters/stdoutsdktrace go.opentelemetry.io/otel/sdk/trace
)func main() {// 创建一个 stdout exporter将 span 输出到控制台exporter, err : stdout.NewExporter(stdout.WithPrettyPrint())if err ! nil {panic(err)}// 创建一个 trace provider使用 stdout exporter 输出 spanprovider : sdktrace.NewTracerProvider(sdktrace.WithBatcher(exporter))// 设置全局 trace providerotel.SetTracerProvider(provider)// 创建一个 span processor将指定的 attribute 添加到指定 trace 下的所有 span 中processor : sdktrace.NewSimpleSpanProcessor(func(span sdktrace.ReadOnlySpan) {// 判断当前 span 是否属于指定的 traceif span.SpanContext().TraceID().String() my_trace_id {// 如果是将指定的 attribute 添加到该 span 上span.SetAttributes(attribute.String(my_attribute, my_value))}})// 将 span processor 添加到 trace provider 中provider.RegisterSpanProcessor(processor)// 创建一个新的 trace 和 spantracer : otel.Tracer(example)ctx, span : tracer.Start(context.Background(), my_span)defer span.End()// 在 span 上设置其他 attributespan.SetAttributes(attribute.String(another_attribute, another_value))// 执行其他操作...
}在上面的示例代码中使用 sdktrace.NewSimpleSpanProcessor 创建了一个简单的 Span Processor该处理器会调用指定的函数并将当前 span 作为参数传递给该函数。在该函数中可以使用 span.SpanContext().TraceID().String() 方法获取当前 span 的 trace ID并根据需要判断是否需要对该 span 添加指定的 attribute。然后将该 Span Processor 添加到 trace provider 中即可让指定 trace 的所有 span 都带上该 attribute。
子 Span 继承父 Span 的属性
当一个 span 手动添加了属性后它的子 span 并不会自动继承这些属性。但是可以通过 OpenTelemetry SDK 提供的 Tracer.Start 方法的第二个参数来指定一个 trace.WithAttributes 选项该选项可以让子 span 继承父 span 的属性。
下面是一个示例代码展示了如何让子 span 集成父 span 的属性
package mainimport (contextgo.opentelemetry.io/otelgo.opentelemetry.io/otel/attributego.opentelemetry.io/otel/exporters/stdoutsdktrace go.opentelemetry.io/otel/sdk/trace
)func main() {// 创建一个 stdout exporter将 span 输出到控制台exporter, err : stdout.NewExporter(stdout.WithPrettyPrint())if err ! nil {panic(err)}// 创建一个 trace provider使用 stdout exporter 输出 spanprovider : sdktrace.NewTracerProvider(sdktrace.WithBatcher(exporter))// 设置全局 trace providerotel.SetTracerProvider(provider)// 创建一个新的 spantracer : otel.Tracer(example)ctx, parentSpan : tracer.Start(context.Background(), parent_span,otel.WithAttributes(attribute.String(parent_attribute, parent_value)),)defer parentSpan.End()// 创建一个子 span并让其继承父 span 的属性ctx, childSpan : tracer.Start(ctx, child_span,otel.WithAttributes(parentSpan.Attributes()...),)defer childSpan.End()// 在子 span 上设置其他属性childSpan.SetAttributes(attribute.String(child_attribute, child_value))// 执行其他操作...
}在上面的示例代码中首先在父 span 上设置了一个属性然后在创建子 span 时使用 trace.WithAttributes(span.Attributes()...) 选项将父 span 的属性传递给子 span这样子 span 就可以继承父 span 的属性了。在子 span 上也可以继续添加其他属性。
如果当前的代码块是在一个 span 中执行的那么可以使用 trace.SpanFromContext(ctx) 获取当前 span然后将其作为父 span。
结合项目 由于 backend_id 是有 venus 产生可以由 venus 服务在 trace 中设置属性 目前 profile 消费的4个阶段只有在第一个阶段UnpackKafkaMessage才能解析到 backend_id而初始化Tracer的代码位于全局且经组员反馈在 SigNoz Web 的 Trace 无法观测到该属性 consumerTracer otel.Tracer(profile-consumer,trace.WithInstrumentationAttributes(attribute.String(profile.work, consumer)))trace.WithInstrumentationAttributes 和 span.SetAttributes 都是用于添加属性attribute到 span 中的方法但它们的作用和使用方式略有不同。 trace.WithInstrumentationAttributes 是用于在创建 Tracer 时添加一些与仪表化相关的属性这些属性会自动添加到由该 Tracer 创建的所有 span 中。它通常用于标识当前 Tracer 所使用的仪表化代码库、版本号、语言等信息。 而 span.SetAttributes 则是用于在创建 span 后手动添加属性这些属性通常用于标识该 span 所对应的操作、请求、响应等信息。它可以在任何时候添加可以添加多个属性也可以添加自定义的属性。
总上考虑暂时使用 在第一个阶段 UnpackKafkaMessage 的 Span 手动添加属性后它的子 Span 去继承 父 Span 的属性
问题
Span 没有 Attributes()只有 ReadOnlySpan有 Attributes() 明日待办
组会讨论 移除关于 Prometheus 的相关配置。。。 导师建议让服务自己监控自己CPU、内存等指标然后上报是否合适。 我建议调研一下 参考uptrace看看他们怎么做服务cpu、内存监控的调研下独立服务监控指标比如hostmetricsreceiver
