rust 日志记载与跟踪
日志Cargo.toml
warp = "0.3.7"
tokio = {version = "1.39.3", features = ["full"]}
serde = { version = "1.0.208", features = ["derive"] }
serde_json = "1.0.125"
#log = "0.4"
#env_logger = "0.11"
#log4rs = "1.3.0"
tracing = {version = "0.1.40", features = ["log"]}
tracing-subscriber = {version = "0.3.18", features = ["env-filter"]}
uuid = {version = "0.8", features = ["v4"]}
日志记载
env_logger
log = "0.4"
env_logger = "0.11"
#log4rs = "1.3.0"
$ RUST_LOG=info cargo run -p wrap_demo01 --bin wrap_demo01
$ RUST_LOG=debug cargo run -p wrap_demo01 --bin wrap_demo01
log4rs
log = "0.4"
#env_logger = "0.11"
log4rs = "1.3.0"
记载 HTTP 请求
[*]输出到控制台
[*]输出到文件
log4rs.yaml 设置
refresh_rate: 30 seconds
appenders:
stdout:
kind: console
encoder:
kind: json
file:
kind: file
path: "stderr.log"
encoder:
kind : json
#pattern: "{d} - {m}{n}"
root:
level: info
appenders:
- stdout
- file
log4rs::init_file("log4rs.yaml", Default::default()).unwrap();
let log = warp::log::custom(|info| {
eprintln!(
"{} {} {} {:?} from {} with {:?}",
info.method(),
info.path(),
info.status(),
info.elapsed(),
info.remote_addr().unwrap(),
info.request_headers()
)
});
let routes = get_questions
.or(add_question)
.or(update_question)
.or(delete_question)
.or(add_answer)
.with(cors)
.with(log)
.recover(error::return_error);
warp::serve(routes).run((, 3030)).await;
创建结构化的日志
let log = warp::log::custom(|info| {
eprintln!(
"{} {} {} {:?} from {} with {:?}",
info.method(),
info.path(),
info.status(),
info.elapsed(),
info.remote_addr().unwrap(),
info.request_headers()
)
});
日志跟踪
tracing = {version = "0.1.40", features = ["log"]}
tracing-subscriber = {version = "0.3.18", features = ["env-filter"]}
let log_filter =
std::env::var("RUST_LOG").unwrap_or_else(|_| "wrap_demo01=info,warp=error".to_owned());
tracing_subscriber::fmt()
.with_env_filter(log_filter)
.with_span_events(FmtSpan::CLOSE)
.init();
// 针对某个请求设置跟踪
let get_questions = warp::get()
.and(warp::path("questions"))
.and(warp::path::end())
.and(warp::query())
.and(store_filter.clone())
.and_then(get_questions)
.with(warp::trace(|info| {
tracing::info_span!("get_questions request", method = %info.method(),
path = %info.path(),
id = %uuid::Uuid::new_v4()) // 可根据 UUID 跟踪某个请求
}));
// 记录每个传入的请求
let routes = get_questions
.or(add_question)
.or(update_question)
.or(delete_question)
.or(add_answer)
.with(cors)
//.with(log)
.with(warp::trace::request())
.recover(error::return_error);
warp::serve(routes).run((, 3030)).await;
}
[*] 未设置 instrument , 单个请求有3条记载
$ cargo run -p wrap_demo01 --bin wrap_demo01
2024-08-23T14:18:45.013769ZINFO get_questions request{method=GET path=/questions id=5828015e-0289-47f1-9a26-16028f54dd3f}: wrap_demo01::routes::question: Querying questions
2024-08-23T14:18:45.013967ZINFO get_questions request{method=GET path=/questions id=5828015e-0289-47f1-9a26-16028f54dd3f}: wrap_demo01::routes::question: pagination=false
2024-08-23T14:18:45.014083ZINFO get_questions request{method=GET path=/questions id=5828015e-0289-47f1-9a26-16028f54dd3f}: wrap_demo01: close time.busy=355µs time.idle=45.9µs
#
pub async fn get_questions(
params: HashMap<String, String>,
store: Store,
) -> Result<impl Reply, Rejection> {
info!("Querying questions");
match extract_pagination(params) {
Ok(pagination) => {
info!(pagination = true);
let questions = store.get(Some(pagination)).await;
Ok(warp::reply::json(&questions))
}
Err(_) => {
info!(pagination = false);
let questions = store.get(None).await;
Ok(warp::reply::json(&questions))
}
}
}
[*] 设置 instrument 后, 单个请求有 4 条记载, 且提供更详细的信息
$ cargo run -p wrap_demo01 --bin wrap_demo01
2024-08-23T14:22:46.631654ZINFO get_questions request{method=GET path=/questions id=da967f3f-ff95-4dc0-bf17-935a38a863e8}:get_questions{params={} store=Store { questions: RwLock { data: {QuestionId("1"): Question { id: QuestionId("1"), title: "How?", content: "Please help!", tags: Some(["general"]) }} }, answers: RwLock { data: {} } }}: wrap_demo01::routes::question: Querying questions
2024-08-23T14:22:46.631765ZINFO get_questions request{method=GET path=/questions id=da967f3f-ff95-4dc0-bf17-935a38a863e8}:get_questions{params={} store=Store { questions: RwLock { data: {QuestionId("1"): Question { id: QuestionId("1"), title: "How?", content: "Please help!", tags: Some(["general"]) }} }, answers: RwLock { data: {} } }}: wrap_demo01::routes::question: pagination=false
2024-08-23T14:22:46.631851ZINFO get_questions request{method=GET path=/questions id=da967f3f-ff95-4dc0-bf17-935a38a863e8}:get_questions{params={} store=Store { questions: RwLock { data: {QuestionId("1"): Question { id: QuestionId("1"), title: "How?", content: "Please help!", tags: Some(["general"]) }} }, answers: RwLock { data: {} } }}: wrap_demo01::routes::question: close time.busy=212µs time.idle=9.73µs
2024-08-23T14:22:46.632025ZINFO get_questions request{method=GET path=/questions id=da967f3f-ff95-4dc0-bf17-935a38a863e8}: wrap_demo01: close time.busy=520µs time.idle=87.6µs
日志调试
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]