feat(http): add error handling for exporting

Author: pafi-code

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/_log_exporter/__init__.py

@@ -171,7 +171,11 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
         serialized_data = encode_logs(batch).SerializeToString()
         deadline_sec = time() + self._timeout
         for retry_num in range(_MAX_RETRYS):
-            resp = self._export(serialized_data, deadline_sec - time())
+            try:
+                resp = self._export(serialized_data, deadline_sec - time())
+            except Exception as error:
+                _logger.error("Failed to export logs batch reason: %s", error)
+                return LogExportResult.FAILURE
             if resp.ok:
                 return LogExportResult.SUCCESS
             # multiplying by a random number between .8 and 1.2 introduces a +/20% jitter to each backoff.

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/metric_exporter/__init__.py

@@ -221,7 +221,11 @@ def export(
         serialized_data = encode_metrics(metrics_data).SerializeToString()
         deadline_sec = time() + self._timeout
         for retry_num in range(_MAX_RETRYS):
-            resp = self._export(serialized_data, deadline_sec - time())
+            try:
+                resp = self._export(serialized_data, deadline_sec - time())
+            except Exception as error:
+                _logger.error("Failed to export metrics batch reason: %s", error)
+                return MetricExportResult.FAILURE
             if resp.ok:
                 return MetricExportResult.SUCCESS
             # multiplying by a random number between .8 and 1.2 introduces a +/20% jitter to each backoff.

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/trace_exporter/__init__.py

@@ -169,7 +169,11 @@ def export(self, spans: Sequence[ReadableSpan]) -> SpanExportResult:
         serialized_data = encode_spans(spans).SerializePartialToString()
         deadline_sec = time() + self._timeout
         for retry_num in range(_MAX_RETRYS):
-            resp = self._export(serialized_data, deadline_sec - time())
+            try:
+                resp = self._export(serialized_data, deadline_sec - time())
+            except Exception as error:
+                _logger.error("Failed to export span batch reason: %s", error)
+                return SpanExportResult.FAILURE
             if resp.ok:
                 return SpanExportResult.SUCCESS
             # multiplying by a random number between .8 and 1.2 introduces a +/20% jitter to each backoff.