源码买卖网站,中国企业新闻观察网,网页设计尺寸规范ps,店铺推广文案http.Client 是 Go 标准库 HTTP 客户端实现#xff0c; sentry-go也没有这个组件#xff0c;所以需要自己实现。 我们只需要对 http.Transport 进行包装即可#xff0c; 完整代码如下
package mainimport (bytesfmtiolog sentry-go也没有这个组件所以需要自己实现。 我们只需要对 http.Transport 进行包装即可 完整代码如下
package mainimport (bytesfmtiolognet/httptimegithub.com/getsentry/sentry-go
)type tracingTransport struct {http.RoundTripper
}func NewTracingTransport(roundTripper http.RoundTripper) *tracingTransport {return tracingTransport{RoundTripper: roundTripper}
}func (t *tracingTransport) RoundTrip(req *http.Request) (*http.Response, error) {operationName : fmt.Sprintf(HTTP %s %s, req.Method, req.URL.String())span : sentry.StartSpan(req.Context(), operationName)defer span.Finish()span.SetTag(url, req.URL.String())if span.Data nil {span.Data make(map[string]interface{})}// reading body from the request body and fill it againvar body []bytevar err errorif req.Body ! nil {body, err io.ReadAll(req.Body)if err ! nil {return nil, err}}// Be careful with including sensitive information in the span,// request body and response may have private user data, which we wouldnt want to expose,// authorization header also is a good example of sensitive data.span.Data[body] string(body)req.Body io.NopCloser(bytes.NewBuffer(body))// adding sentry header for distributed tracingreq.Header.Add(sentry-trace, span.TraceID.String())response, err : t.RoundTripper.RoundTrip(req)span.Data[http_code] response.StatusCode// could additionally add the response to the span datareturn response, err
}func main() {err : sentry.Init(sentry.ClientOptions{Debug: true,Dsn: https://a5eac4fa3396cbfac8fb4baa6a9c03a3o4504291071688704.ingest.sentry.io/4506715873804288,AttachStacktrace: true,EnableTracing: true,SampleRate: 1.0,TracesSampleRate: 1.0,ProfilesSampleRate: 1.0,})if err ! nil {log.Fatalf(sentry.Init: %s, err)}defer sentry.Flush(2 * time.Second)client : http.Client{Transport: NewTracingTransport(http.DefaultTransport),}res, err : client.Get(http://httpbin.org/get)if err ! nil {log.Fatalf(client Get: %s, err)}defer res.Body.Close()body, err : io.ReadAll(res.Body)if err ! nil {log.Fatalf(io.ReadAll: %s, err)}fmt.Println(string(body))
}
参考: https://anymindgroup.com/news/tech-blog/15724/
