Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: Use debug level to log requests 

Part of #1188
pull/24376/head
Marko Mikulicic 2021-04-13 16:56:18 +02:00 committed by kodiakhq[bot]
parent 871de60bb7
commit ee46764a2d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/influxdb_ioxd/http.rs
View File

@ -32,7 +32,7 @@ use http::header::{CONTENT_ENCODING, CONTENT_TYPE};
use hyper::{Body, Method, Request, Response, StatusCode}; use hyper::{Body, Method, Request, Response, StatusCode};
use observability_deps::{ use observability_deps::{
opentelemetry::KeyValue, opentelemetry::KeyValue,
tracing::{self, debug, error, info}, tracing::{self, debug, error},
}; };
use routerify::{prelude::*, Middleware, RequestInfo, Router, RouterError, RouterService}; use routerify::{prelude::*, Middleware, RequestInfo, Router, RouterError, RouterService};
use serde::Deserialize; use serde::Deserialize;
@ -312,11 +312,11 @@ where
Router::builder() Router::builder()
.data(server) .data(server)
.middleware(Middleware::pre(|req| async move { .middleware(Middleware::pre(|req| async move {
info!(request = ?req, "Processing request"); debug!(request = ?req, "Processing request");
Ok(req) Ok(req)
})) }))
.middleware(Middleware::post(|res| async move { .middleware(Middleware::post(|res| async move {
info!(response = ?res, "Successfully processed request"); debug!(response = ?res, "Successfully processed request");
Ok(res) Ok(res)
})) // this endpoint is for API backward compatibility with InfluxDB 2.x })) // this endpoint is for API backward compatibility with InfluxDB 2.x
.post("/api/v2/write", write::<M>) .post("/api/v2/write", write::<M>)