From 6eb7efcb760ed471013c889c6c2656f04d36066a Mon Sep 17 00:00:00 2001 From: shuiyisong <113876041+shuiyisong@users.noreply.github.com> Date: Thu, 13 Nov 2025 15:15:26 +0800 Subject: [PATCH] chore: add debug log on receiving logs (#7211) * chore: add debug log on receiving logs Signed-off-by: shuiyisong * chore: add debug log on receiving logs Signed-off-by: shuiyisong --------- Signed-off-by: shuiyisong --- src/servers/src/http/event.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/servers/src/http/event.rs b/src/servers/src/http/event.rs index 24bb844dc7..2390e374a1 100644 --- a/src/servers/src/http/event.rs +++ b/src/servers/src/http/event.rs @@ -31,7 +31,7 @@ use axum_extra::TypedHeader; use common_catalog::consts::default_engine; use common_error::ext::{BoxedError, ErrorExt}; use common_query::{Output, OutputData}; -use common_telemetry::{error, warn}; +use common_telemetry::{debug, error, warn}; use headers::ContentType; use lazy_static::lazy_static; use mime_guess::mime; @@ -738,6 +738,11 @@ pub async fn log_ingester( let value = extract_pipeline_value_by_content_type(content_type, payload, ignore_errors)?; + debug!( + "receiving logs: {:?}", + serde_json::to_string(&value).unwrap() + ); + query_ctx.set_channel(Channel::Log); let query_ctx = Arc::new(query_ctx);