chore: Add error logging for failed OpenTelemetry HTTP export (open-t…

…elemetry#1498) Co-authored-by: Lalit Kumar Bhasin <[email protected]> Co-authored-by: Cijo Thomas <[email protected]>
KallDrexx · Feb 1, 2024 · d19187d · d19187d
1 parent 57c3aa3
commit d19187d
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 2 deletions.
diff --git a/opentelemetry-otlp/src/exporter/http/logs.rs b/opentelemetry-otlp/src/exporter/http/logs.rs
@@ -31,7 +31,18 @@ impl LogExporter for OtlpHttpClient {
             request.headers_mut().insert(k.clone(), v.clone());
         }
 
-        client.send(request).await?;
+        let request_uri = request.uri().to_string();
+        let response = client.send(request).await?;
+
+        if !response.status().is_success() {
+            let error = format!(
+                "OpenTelemetry logs export failed. Url: {}, Status Code: {}, Response: {:?}",
+                response.status().as_u16(),
+                request_uri,
+                response.body()
+            );
+            return Err(LogError::Other(error.into()));
+        }
 
         Ok(())
     }

diff --git a/opentelemetry-otlp/src/exporter/http/trace.rs b/opentelemetry-otlp/src/exporter/http/trace.rs
@@ -46,7 +46,18 @@ impl SpanExporter for OtlpHttpClient {
         }
 
         Box::pin(async move {
-            client.send(request).await?;
+            let request_uri = request.uri().to_string();
+            let response = client.send(request).await?;
+
+            if !response.status().is_success() {
+                let error = format!(
+                    "OpenTelemetry trace export failed. Url: {}, Status Code: {}, Response: {:?}",
+                    response.status().as_u16(),
+                    request_uri,
+                    response.body()
+                );
+                return Err(TraceError::Other(error.into()));
+            }
 
             Ok(())
         })