Полная трассировка с помощью zipkin-go

У меня есть услуги. Я хочу отследить эти службы с помощью zipkin-go. В каждой службе я вызываю некоторые из моих других внутренних служб или вызовов db. Я хочу отслеживать каждую активность, например, сколько времени потребовалось для вызова внутренних служб или db. Я реализовал, используя доступные учебные пособия в Интернете. Ниже мой код:

package main

import (
"fmt"
"os"
"net/http"
"log"
"github.com/gorilla/handlers"
"github.com/gorilla/mux"
"Upload-Image-API/services/controllers/updatemodrefid"
"Upload-Image-API/services/controllers/uploadimage"
"Upload-Image-API/services/utils"
"github.com/openzipkin/zipkin-go"
"github.com/openzipkin/zipkin-go/model"
zipkinhttp "github.com/openzipkin/zipkin-go/middleware/http"
reporterhttp "github.com/openzipkin/zipkin-go/reporter/http"
)

const endpointURL = "http://localhost:9411/api/v2/spans"

func newTracer() (*zipkin.Tracer, error) {
   // The reporter sends traces to zipkin server
   reporter := reporterhttp.NewReporter(endpointURL)
   port := utils.GetString("serviceListeningPort")
   if port == "" {
        fmt.Println("Port is not defined in configuration ...!!!")
        os.Exit(1)
   }
   // Local endpoint represent the local service information
   localEndpoint := &model.Endpoint{ServiceName: "Upload-Image-API", Port: 7795}

   // Sampler tells you which traces are going to be sampled or not. In this case we will record 100% (1.00) of traces.
   sampler, err := zipkin.NewCountingSampler(1)
   if err != nil {
      return nil, err
   }

   t, err := zipkin.NewTracer(
      reporter,
      zipkin.WithSampler(sampler),
      zipkin.WithLocalEndpoint(localEndpoint),
   )
   if err != nil {
      return nil, err
   }

   return t, err
}


func main() {
    var err error
    var environment = os.Args[1]
    err = utils.LoadDefaultConfig(environment)
    tracer, err := newTracer()
    if err != nil {
      log.Fatal(err)
    }
    // We add the instrumented transport to the defaultClient
    // that comes with the zipkin-go library
    http.DefaultClient.Transport, err = zipkinhttp.NewTransport(
        tracer,
        zipkinhttp.TransportTrace(true),
    )
    if err != nil {
      log.Fatal(err)
    }
    if err != nil {
        fmt.Println("Could not load the configuration because of following err " + err.Error() + " ...!!!")
        os.Exit(1)
    } else {
        fmt.Println("Configurations sucessfully loaded for environment " + environment + " ...!!!")
    }
    allowedHeaders := handlers.AllowedHeaders([]string{"X-Requested-With"})
    allowedOrigins := handlers.AllowedOrigins([]string{"*"})
    allowedMethods := handlers.AllowedMethods([]string{"GET", "HEAD", "POST", "PUT", "DELETE", "OPTIONS"})

    port := utils.GetString("serviceListeningPort")
    if port == "" {
        fmt.Println("Port is not defined in configuration ...!!!")
        os.Exit(1)
    }
    router := mux.NewRouter().StrictSlash(true)
    router.HandleFunc("/uploadimage", uploadimage.UploadImages).Methods("POST", "GET")
    router.HandleFunc("/updatemodrefid", updatemodrefid.UpdateModRefId).Methods("POST", "GET")
    router.Use(zipkinhttp.NewServerMiddleware(
  tracer,
  zipkinhttp.SpanName("request")), // name for request span
)
    err = http.ListenAndServe(port, handlers.CORS(allowedHeaders, allowedOrigins, allowedMethods)(router))
    if err != nil {
        fmt.Println("Count not start the server because of following err " + err.Error())
        return
    }
}

Мой запрос отслеживается, но я не могу отследить, что происходит внутри контроллера uploadimage. Ниже приведен снимок экрана моего пользовательского интерфейса zipkin:

Zipkin UI

Я хочу отслеживать все действия, происходящие внутри контроллера uploadimage. Что мне нужно передать, чтобы я мог все проследить.


person Devendra Verma    schedule 29.08.2019    source источник


Ответы (1)


Я новичок в zipkin и golang, если вы хотите отслеживать внутренний процесс, вы можете создать диапазон из контекста

пример: скажем, у вас есть api с именем Login, внутри входа вы можете выполнять операцию с базой данных или любые другие операции

func Login(res http.ResponseWriter, req *http.Request) {
    span, _ := tracer.StartSpanFromContext(req.Context(), "database")
    databaseOperation()
    span.Finish()
}
person Pram    schedule 21.09.2019