remove metrics exporter

Author: yiyuan-he

exporters/aws-otel-otlp-udp-exporter/src/amazon/opentelemetry/exporters/otlp/udp/__init__.py

@@ -3,22 +3,18 @@
 
 from .exporter import (
     DEFAULT_ENDPOINT,
-    FORMAT_OTEL_METRICS_BINARY_PREFIX,
     FORMAT_OTEL_SAMPLED_TRACES_BINARY_PREFIX,
     FORMAT_OTEL_UNSAMPLED_TRACES_BINARY_PREFIX,
     PROTOCOL_HEADER,
-    OTLPUdpMetricExporter,
     OTLPUdpSpanExporter,
     UdpExporter,
 )
 
 __all__ = [
     "UdpExporter",
-    "OTLPUdpMetricExporter",
     "OTLPUdpSpanExporter",
     "DEFAULT_ENDPOINT",
     "FORMAT_OTEL_SAMPLED_TRACES_BINARY_PREFIX",
     "FORMAT_OTEL_UNSAMPLED_TRACES_BINARY_PREFIX",
     "PROTOCOL_HEADER",
-    "FORMAT_OTEL_METRICS_BINARY_PREFIX",
 ]

exporters/aws-otel-otlp-udp-exporter/src/amazon/opentelemetry/exporters/otlp/udp/exporter.py

@@ -4,23 +4,16 @@
 import os
 import socket
 from logging import Logger, getLogger
-from typing import Dict, Optional, Sequence, Tuple
+from typing import Optional, Sequence, Tuple
 
 from typing_extensions import override
 
-from opentelemetry.exporter.otlp.proto.common.metrics_encoder import encode_metrics
 from opentelemetry.exporter.otlp.proto.common.trace_encoder import encode_spans
-from opentelemetry.sdk.metrics._internal.aggregation import AggregationTemporality
-from opentelemetry.sdk.metrics._internal.export import MetricExportResult
-from opentelemetry.sdk.metrics._internal.point import MetricsData
-from opentelemetry.sdk.metrics.export import MetricExporter
-from opentelemetry.sdk.metrics.view import Aggregation
 from opentelemetry.sdk.trace import ReadableSpan
 from opentelemetry.sdk.trace.export import SpanExporter, SpanExportResult
 
 DEFAULT_ENDPOINT = "127.0.0.1:2000"
 PROTOCOL_HEADER = '{"format":"json","version":1}\n'
-FORMAT_OTEL_METRICS_BINARY_PREFIX = "M1"
 
 FORMAT_OTEL_SAMPLED_TRACES_BINARY_PREFIX = "T1S"
 FORMAT_OTEL_UNSAMPLED_TRACES_BINARY_PREFIX = "T1U"
@@ -66,44 +59,6 @@ def _parse_endpoint(self, endpoint: str) -> Tuple[str, int]:
         return host, port
 
 
-class OTLPUdpMetricExporter(MetricExporter):
-    def __init__(
-        self,
-        endpoint: Optional[str] = None,
-        preferred_temporality: Dict[type, AggregationTemporality] = None,
-        preferred_aggregation: Dict[type, Aggregation] = None,
-    ):
-        super().__init__(
-            preferred_temporality=preferred_temporality,
-            preferred_aggregation=preferred_aggregation,
-        )
-        self._udp_exporter = UdpExporter(endpoint=endpoint)
-
-    @override
-    def export(
-        self,
-        metrics_data: MetricsData,
-        timeout_millis: float = 10_000,
-        **kwargs,
-    ) -> MetricExportResult:
-        serialized_data = encode_metrics(metrics_data).SerializeToString()
-
-        try:
-            self._udp_exporter.send_data(data=serialized_data, signal_format_prefix=FORMAT_OTEL_METRICS_BINARY_PREFIX)
-            return MetricExportResult.SUCCESS
-        except Exception as exc:  # pylint: disable=broad-except
-            _logger.error("Error exporting metrics: %s", exc)
-            return MetricExportResult.FAILURE
-
-    # pylint: disable=no-self-use
-    def force_flush(self, timeout_millis: float = 10_000) -> bool:
-        # TODO: implement force flush
-        return True
-
-    def shutdown(self, timeout_millis: float = 30_000, **kwargs) -> None:
-        self._udp_exporter.shutdown()
-
-
 class OTLPUdpSpanExporter(SpanExporter):
     def __init__(self, endpoint: Optional[str] = None, sampled: bool = True):
         self._udp_exporter = UdpExporter(endpoint=endpoint)

exporters/aws-otel-otlp-udp-exporter/tests/test_exporter.py

@@ -11,11 +11,9 @@
     FORMAT_OTEL_SAMPLED_TRACES_BINARY_PREFIX,
     FORMAT_OTEL_UNSAMPLED_TRACES_BINARY_PREFIX,
     PROTOCOL_HEADER,
-    OTLPUdpMetricExporter,
     OTLPUdpSpanExporter,
     UdpExporter,
 )
-from opentelemetry.sdk.metrics._internal.export import MetricExportResult
 from opentelemetry.sdk.trace.export import SpanExportResult
 
 
@@ -63,40 +61,6 @@ def test_shutdown(self, mock_socket):
         mock_socket_instance.close.assert_called_once()
 
 
-class TestOTLPUdpMetricExporter(unittest.TestCase):
-
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.encode_metrics")
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
-    def test_export(self, mock_udp_exporter, mock_encode_metrics):
-        mock_udp_exporter_instance = mock_udp_exporter.return_value
-        mock_encoded_data = MagicMock()
-        mock_encode_metrics.return_value.SerializeToString.return_value = mock_encoded_data
-        exporter = OTLPUdpMetricExporter()
-        result = exporter.export(MagicMock())
-        mock_udp_exporter_instance.send_data.assert_called_once_with(data=mock_encoded_data, signal_format_prefix="M1")
-        self.assertEqual(result, MetricExportResult.SUCCESS)
-
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.encode_metrics")
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
-    def test_export_with_exception(self, mock_udp_exporter, mock_encode_metrics):
-        mock_udp_exporter_instance = mock_udp_exporter.return_value
-        mock_encoded_data = MagicMock()
-        mock_encode_metrics.return_value.SerializeToString.return_value = mock_encoded_data
-        mock_udp_exporter_instance.send_data.side_effect = Exception("Something went wrong")
-        exporter = OTLPUdpMetricExporter()
-        result = exporter.export(MagicMock())
-        self.assertEqual(result, MetricExportResult.FAILURE)
-
-    # pylint: disable=no-self-use
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
-    def test_shutdown(self, mock_udp_exporter):
-        mock_udp_exporter_instance = mock_udp_exporter.return_value
-        exporter = OTLPUdpMetricExporter()
-        exporter.force_flush()
-        exporter.shutdown()
-        mock_udp_exporter_instance.shutdown.assert_called_once()
-
-
 class TestOTLPUdpSpanExporter(unittest.TestCase):
 
     @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.encode_spans")