bugfix(exporter): ensure response is closed

Fix open-telemetry#4476

Signed-off-by: Alex Boten <[email protected]>

Author: codeboten

CHANGELOG.md

@@ -32,6 +32,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   ([#4406](https://github.com/open-telemetry/opentelemetry-python/pull/4406))
 - Fix env var error message for TraceLimits/SpanLimits
   ([#4458](https://github.com/open-telemetry/opentelemetry-python/pull/4458))
+- Fix intermittent `Connection aborted` error when using otlp/http exporters
+  ([#4477](https://github.com/open-telemetry/opentelemetry-python/pull/4477))
 
 ## Version 1.30.0/0.51b0 (2025-02-03)
 

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

@@ -167,8 +167,10 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
             resp = self._export(serialized_data)
             # pylint: disable=no-else-return
             if resp.ok:
+                resp.close()
                 return LogExportResult.SUCCESS
             elif self._retryable(resp):
+                resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting logs batch, retrying in %ss.",
                     resp.reason,
@@ -177,6 +179,7 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
                 sleep(delay)
                 continue
             else:
+                resp.close()
                 _logger.error(
                     "Failed to export logs batch code: %s, reason: %s",
                     resp.status_code,

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

@@ -206,8 +206,10 @@ def export(
             resp = self._export(serialized_data.SerializeToString())
             # pylint: disable=no-else-return
             if resp.ok:
+                resp.close()
                 return MetricExportResult.SUCCESS
             elif self._retryable(resp):
+                resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting metric batch, retrying in %ss.",
                     resp.reason,
@@ -216,6 +218,7 @@ def export(
                 sleep(delay)
                 continue
             else:
+                resp.close()
                 _logger.error(
                     "Failed to export batch code: %s, reason: %s",
                     resp.status_code,

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

@@ -159,8 +159,10 @@ def _export_serialized_spans(self, serialized_data):
             resp = self._export(serialized_data)
             # pylint: disable=no-else-return
             if resp.ok:
+                resp.close()
                 return SpanExportResult.SUCCESS
             elif self._retryable(resp):
+                resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting span batch, retrying in %ss.",
                     resp.reason,
@@ -169,6 +171,7 @@ def _export_serialized_spans(self, serialized_data):
                 sleep(delay)
                 continue
             else:
+                resp.close()
                 _logger.error(
                     "Failed to export batch code: %s, reason: %s",
                     resp.status_code,