Golang错误处理如何与OpenTelemetry追踪结合 添加错误标签的实践

package main

import (
    "context"
    "fmt"
    "log"
    "net/http"
    "os"

    "github.com/pkg/errors"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/attribute"
    "go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
    "go.opentelemetry.io/otel/sdk/resource"
    sdktrace "go.opentelemetry.io/otel/sdk/trace"
    "go.opentelemetry.io/otel/trace"
)

var tracer trace.Tracer

func initTracer() *sdktrace.TracerProvider {
    exporter, err := stdouttrace.New(stdouttrace.WithWriter(os.Stdout))
    if err != nil {
        log.Fatal(err)
    }
    tp := sdktrace.NewTracerProvider(
        sdktrace.WithSampler(sdktrace.AlwaysSample()),
        sdktrace.WithBatcher(exporter),
        sdktrace.WithResource(resource.NewWithAttributes(
            "https://opentelemetry.io/schemas/1.19.0",
            attribute.String("service.name", "error-example"),
            attribute.String("environment", "demo"),
        )),
    )
    otel.SetTracerProvider(tp)
    tracer = otel.Tracer("error-example")
    return tp
}

func doSomething(ctx context.Context, input string) error {
    ctx, span := tracer.Start(ctx, "doSomething")
    defer span.End()

    if input == "error" {
        err := errors.New("input is error")
        span.RecordError(err)
        span.SetAttributes(attribute.String("error.message", err.Error()))
        return errors.Wrap(err, "failed to do something")
    }

    return nil
}

func handler(w http.ResponseWriter, r *http.Request) {
    ctx := r.Context()
    ctx, span := tracer.Start(ctx, "handler")
    defer span.End()

    input := r.URL.Query().Get("input")
    err := doSomething(ctx, input)
    if err != nil {
        span.RecordError(err)
        span.SetAttributes(attribute.String("error.message", err.Error()))
        w.WriteHeader(http.StatusInternalServerError)
        fmt.Fprintf(w, "Error: %v", err)
        return
    }

    fmt.Fprintf(w, "Success!")
}

func main() {
    tp := initTracer()
    defer func() {
        if err := tp.Shutdown(context.Background()); err != nil {
            log.Printf("Error shutting down tracer provider: %v", err)
        }
    }()

    http.HandleFunc("/", handler)
    log.Println("Server listening on port 8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}