@setupx
Go & TS developer

Opentelemtry +?

В общем появилась надобность сделать метрики/трассировку в приложении, я остановился на Opentelemtry и налепил вот такой код(искал по гитхабу прмиеры):
code

package main

import (
	"context"
	"github.com/go-chi/chi/v5"
	"log"
	"net/http"
	"os"
	"time"

	"github.com/go-chi/chi/v5/middleware"

	"go.opentelemetry.io/otel"
	"go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp"
	"go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
	"go.opentelemetry.io/otel/sdk/resource"
	oteltrace "go.opentelemetry.io/otel/sdk/trace"
	sdktrace "go.opentelemetry.io/otel/sdk/trace"
	semconv "go.opentelemetry.io/otel/semconv/v1.26.0"
	"go.opentelemetry.io/otel/trace"
)

var (
	tracer       trace.Tracer
	otlpEndpoint string
)

func init() {
	otlpEndpoint = os.Getenv("OTLP_ENDPOINT")
	if otlpEndpoint == "" {
		otlpEndpoint = "localhost:4318"
	}
}

// Console Exporter, only for testing
func newConsoleExporter() (oteltrace.SpanExporter, error) {
	return stdouttrace.New()
}

// OTLP Exporter
func newOTLPExporter(ctx context.Context) (oteltrace.SpanExporter, error) {
	insecureOpt := otlptracehttp.WithInsecure()

	endpointOpt := otlptracehttp.WithEndpoint(otlpEndpoint)

	return otlptracehttp.New(ctx, insecureOpt, endpointOpt)
}

func newTraceProvider(exp sdktrace.SpanExporter) *sdktrace.TracerProvider {
	r, err := resource.Merge(
		resource.Default(),
		resource.NewWithAttributes(
			semconv.SchemaURL,
			semconv.ServiceName("myapp"),
		),
	)

	if err != nil {
		panic(err)
	}

	return sdktrace.NewTracerProvider(
		sdktrace.WithBatcher(exp),
		sdktrace.WithResource(r),
	)
}

func main() {
	ctx := context.Background()

	// For testing to print out traces to the console
	exp, err := newConsoleExporter()
	//exp, err := newOTLPExporter(ctx)

	if err != nil {
		log.Fatalf("failed to initialize exporter: %v", err)
	}

	tp := newTraceProvider(exp)

	defer func() { _ = tp.Shutdown(ctx) }()

	otel.SetTracerProvider(tp)

	tracer = tp.Tracer("myapp")

	r := chi.NewRouter()
	r.Use(middleware.Logger)

	r.Get("/devices", getDevices)
	http.ListenAndServe(":8080", r)

	log.Println("okay")
}

func getDevices(w http.ResponseWriter, r *http.Request) {
	ctx, span := tracer.Start(r.Context(), "HTTP GET /devices")
	defer span.End()

	// Simulate Database call to fetch connected devices.
	db(ctx)

	// Add additional delay to simulate HTTP request.
	time.Sleep(1 * time.Second)

	// Return devices
	w.Write([]byte("ok"))
}

func db(ctx context.Context) {
	_, span := tracer.Start(ctx, "SQL SELECT")
	defer span.End()

	// Simulate Database call to SELECT connected devices.
	time.Sleep(2 * time.Second)
}



И в консоли все появляется:
image

66e1ee6250389055177438.png


Уже второй день ищу информацию по моему вопросу и почти все используют либу https://github.com/jaegertracing/jaeger-client-go , которая я так понял уже не развивается, а только фиксит баги/ошибки(как-то не хочется потом переписывать на более развивающийся)

Как мне прикрутить UI, Prometheus/Grafana, чтобы можно было контролировать в виде графиков?
  • Вопрос задан
  • 118 просмотров
Пригласить эксперта
Ответы на вопрос 1
Prometheus это про метрики

Grafana это тоже про метрики

Судя по коду, вы сделали поддержку трейсинга в вашем приложении, а чтобы смотреть трейсы, нужно развернуть интерфейс Jaeger. https://www.jaegertracing.io/

Есть статья на эту тему https://habr.com/ru/articles/710644/
Ответ написан
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы