Append v1/logs for OTLP endpoint

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

@@ -46,7 +46,8 @@
 
 
 DEFAULT_COMPRESSION = Compression.NoCompression
-DEFAULT_ENDPOINT = "http://localhost:4318/v1/logs"
+DEFAULT_ENDPOINT = "http://localhost:4318/"
+DEFAULT_LOGS_EXPORT_PATH = "v1/logs"
 DEFAULT_TIMEOUT = 10  # in seconds
 
 
@@ -62,8 +63,8 @@ def __init__(
         timeout: Optional[int] = None,
         compression: Optional[Compression] = None,
     ):
-        self._endpoint = endpoint or environ.get(
-            OTEL_EXPORTER_OTLP_ENDPOINT, DEFAULT_ENDPOINT
+        self._endpoint = endpoint or _append_logs_path(
+            environ.get(OTEL_EXPORTER_OTLP_ENDPOINT, DEFAULT_ENDPOINT)
         )
         self._certificate_file = certificate_file or environ.get(
             OTEL_EXPORTER_OTLP_CERTIFICATE, True
@@ -158,3 +159,9 @@ def _compression_from_env() -> Compression:
         environ.get(OTEL_EXPORTER_OTLP_COMPRESSION, "none").lower().strip()
     )
     return Compression(compression)
+
+
+def _append_logs_path(endpoint: str) -> str:
+    if endpoint.endswith("/"):
+        return endpoint + DEFAULT_LOGS_EXPORT_PATH
+    return endpoint + f"/{DEFAULT_LOGS_EXPORT_PATH}"

exporter/opentelemetry-exporter-otlp-proto-http/tests/test_proto_log_exporter.py

@@ -23,6 +23,7 @@
     DEFAULT_COMPRESSION,
     DEFAULT_ENDPOINT,
     DEFAULT_TIMEOUT,
+    DEFAULT_LOGS_EXPORT_PATH,
     OTLPLogExporter,
 )
 from opentelemetry.exporter.otlp.proto.http._log_exporter.encoder import (
@@ -62,7 +63,7 @@
 from opentelemetry.sdk.util.instrumentation import InstrumentationScope
 from opentelemetry.trace import TraceFlags
 
-ENV_ENDPOINT = "http://localhost.env:8080/logs"
+ENV_ENDPOINT = "http://localhost.env:8080/"
 ENV_CERTIFICATE = "/etc/base.crt"
 ENV_HEADERS = "envHeader1=val1,envHeader2=val2"
 ENV_TIMEOUT = "30"
@@ -73,7 +74,9 @@ def test_constructor_default(self):
 
         exporter = OTLPLogExporter()
 
-        self.assertEqual(exporter._endpoint, DEFAULT_ENDPOINT)
+        self.assertEqual(
+            exporter._endpoint, DEFAULT_ENDPOINT + DEFAULT_LOGS_EXPORT_PATH
+        )
         self.assertEqual(exporter._certificate_file, True)
         self.assertEqual(exporter._timeout, DEFAULT_TIMEOUT)
         self.assertIs(exporter._compression, DEFAULT_COMPRESSION)
@@ -121,7 +124,9 @@ def test_exporter_env(self):
 
         exporter = OTLPLogExporter()
 
-        self.assertEqual(exporter._endpoint, ENV_ENDPOINT)
+        self.assertEqual(
+            exporter._endpoint, ENV_ENDPOINT + DEFAULT_LOGS_EXPORT_PATH
+        )
         self.assertEqual(exporter._certificate_file, ENV_CERTIFICATE)
         self.assertEqual(exporter._timeout, int(ENV_TIMEOUT))
         self.assertIs(exporter._compression, Compression.Gzip)