Http metric exporter init with batch_size, add split_metrics_data

Author: tammy-baylis-swi

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

@@ -37,6 +37,7 @@
 )
 from opentelemetry.exporter.otlp.proto.common._internal.metrics_encoder import (
     OTLPMetricExporterMixin,
+    split_metrics_data,
 )
 from opentelemetry.exporter.otlp.proto.common.metrics_encoder import (
     encode_metrics,
@@ -116,7 +117,29 @@ def __init__(
         preferred_temporality: dict[type, AggregationTemporality]
         | None = None,
         preferred_aggregation: dict[type, Aggregation] | None = None,
+        max_export_batch_size: int | None = None,
     ):
+        """OTLP HTTP metrics exporter
+
+        Args:
+            endpoint: Target URL to which the exporter is going to send metrics
+            certificate_file: Path to the certificate file to use for any TLS
+            client_key_file: Path to the client key file to use for any TLS
+            client_certificate_file: Path to the client certificate file to use for any TLS
+            headers: Headers to be sent with HTTP requests at export
+            timeout: Timeout in seconds for export
+            compression: Compression to use; one of none, gzip, deflate
+            session: Requests session to use at export
+            preferred_temporality: Map of preferred temporality for each metric type.
+                See `opentelemetry.sdk.metrics.export.MetricReader` for more details on what
+                preferred temporality is.
+            preferred_aggregation: Map of preferred aggregation for each metric type.
+                See `opentelemetry.sdk.metrics.export.MetricReader` for more details on what
+                preferred aggregation is.
+            max_export_batch_size: Maximum number of data points to export in a single request.
+                If not set there is no limit to the number of data points in a request.
+                If it is set and the number of data points exceeds the max, the request will be split.
+        """
         self._endpoint = endpoint or environ.get(
             OTEL_EXPORTER_OTLP_METRICS_ENDPOINT,
             _append_metrics_path(
@@ -166,6 +189,8 @@ def __init__(
             preferred_temporality, preferred_aggregation
         )
 
+        self._max_export_batch_size: int | None = max_export_batch_size
+
     def _export(self, serialized_data: bytes):
         data = serialized_data
         if self._compression == Compression.Gzip:
@@ -240,6 +265,15 @@ def export(
                 return MetricExportResult.FAILURE
         return MetricExportResult.FAILURE
 
+    def _split_metrics_data(
+        self,
+        metrics_data: MetricsData,
+    ) -> Iterable[MetricsData]:
+        return split_metrics_data(
+            metrics_data,
+            self._max_export_batch_size,
+        )
+
     def shutdown(self, timeout_millis: float = 30_000, **kwargs) -> None:
         pass