axum-tracing-opentelemetry

集成axum + 跟踪 + opentelemetry的中间件。

• 从传入请求中读取OpenTelemetry头部
• 如果传入请求中没有找到跟踪，则开始一个新的跟踪
• 跟踪附加到跟踪的span上
• 在跟踪的span关闭时创建OpenTelemetry Span（从[tracing-opentelemetry]的行为）

有关示例，您可以查看示例文件夹。

//...
use axum_tracing_opentelemetry::opentelemetry_tracing_layer;

#[tokio::main]
async fn main() -> Result<(), axum::BoxError> {
    // very opinionated init of tracing, look as is source to make your own
    init_tracing_opentelemetry::tracing_subscriber_ext::init_subscribers()?;

    let app = app();
    // run it
    let addr = &"0.0.0.0:3000".parse::<SocketAddr>()?;
    tracing::warn!("listening on {}", addr);
    let listener = tokio::net::TcpListener::bind(addr).await?;
    axum::serve(listener, app.into_make_service())
        //FIXME .with_graceful_shutdown(shutdown_signal())
        .await?;
    Ok(())
}

fn app() -> Router {
    Router::new()
        .route("/", get(index)) // request processed inside span
        // include trace context as header into the response
        .layer(OtelInResponseLayer::default())
        //start OpenTelemetry trace on incoming request
        .layer(OtelAxumLayer::default())
        .route("/health", get(health)) // request processed without span / trace
}

async fn shutdown_signal() {
    //...
    opentelemetry::global::shutdown_tracer_provider();
}

有关初始化的更多信息，您可以查看crate init-tracing-opentelemetry 或 tracing-opentelemetry。

变更日志 - 历史

CHANGELOG.md