我正在实现 tokio/axum HTTP 服务器。在运行服务器的函数中,我配置路由、添加共享应用程序服务并添加跟踪层。
我的跟踪配置如下所示:
let tracing_layer = TraceLayer::new_for_http()
.make_span_with(|_request: &Request<Body>| {
let request_id = Uuid::new_v4().to_string();
tracing::info_span!("http-request", %request_id)
})
.on_request(|request: &Request<Body>, _span: &Span| {
tracing::info!("request: {} {}", request.method(), request.uri().path())
})
.on_response(
|response: &Response<BoxBody>, latency: Duration, _span: &Span| {
tracing::info!("response: {} {:?}", response.status(), latency)
},
)
.on_failure(
|error: ServerErrorsFailureClass, _latency: Duration, _span: &Span| {
tracing::error!("error: {}", error)
},
);
let app = Router::new()
// routes
.layer(tracing_layer)
// other layers
...
Run Code Online (Sandbox Code Playgroud)
为了稍微组织一下代码,我将跟踪层配置移动到一个单独的函数中。诀窍是为此函数提供一个编译返回类型。
第一种方法是按原样移动代码并让 IDE 生成返回类型:
TraceLayer<SharedClassifier<ServerErrorsAsFailures>, fn(&Request<Body>) -> Span, fn(&Request<Body>, &Span), fn(&Response<BoxBody>, …Run Code Online (Sandbox Code Playgroud)