Example exporter customizer.

Author: DylanRussell

exportercustomizer/gcp/README.rst

@@ -0,0 +1 @@
+OTLP exporter customizer for python auto instrumentation.

exportercustomizer/gcp/pyproject.toml

@@ -0,0 +1,47 @@
+[build-system]
+requires = ["hatchling"]
+build-backend = "hatchling.build"
+
+[project]
+name = "opentelemetry-instrumentation-exporter-customizer-component"
+dynamic = ["version"]
+description = "OpenTelemetry OTLP exporter customizer"
+readme = "README.rst"
+license = "Apache-2.0"
+requires-python = ">=3.8"
+authors = [
+  { name = "OpenTelemetry Authors", email = "[email protected]" },
+]
+classifiers = [
+  "Development Status :: 4 - Beta",
+  "Intended Audience :: Developers",
+  "License :: OSI Approved :: Apache Software License",
+  "Programming Language :: Python",
+  "Programming Language :: Python :: 3",
+  "Programming Language :: Python :: 3.8",
+  "Programming Language :: Python :: 3.9",
+  "Programming Language :: Python :: 3.10",
+  "Programming Language :: Python :: 3.11",
+  "Programming Language :: Python :: 3.12",
+  "Programming Language :: Python :: 3.13",
+]
+dependencies = [
+  "google-auth ~= 2.38",
+  "grpcio ~= 1.7",
+  "opentelemetry-exporter-otlp-proto-grpc ~= 1.3",
+  "opentelemetry-exporter-otlp-customizer ~= 1.3",
+]
+
+[project.entry-points.opentelemetry_otlp_exporter_customizer]
+google_otlp_customizer = "opentelemetry.auth.gcp:GoogleOTLPExporterCustomizer"
+
+[tool.hatch.version]
+path = "src/opentelemetry/auth/gcp/version.py"
+
+[tool.hatch.build.targets.sdist]
+include = [
+  "/src",
+]
+
+[tool.hatch.build.targets.wheel]
+packages = ["src/opentelemetry"]

exportercustomizer/gcp/src/opentelemetry/auth/gcp/__init__.py

@@ -0,0 +1,45 @@
+import inspect
+from typing import Tuple
+
+import google.auth
+import grpc
+from google.auth.transport import requests
+from google.auth.transport.grpc import AuthMetadataPlugin
+from google.auth.transport.requests import AuthorizedSession
+
+from opentelemetry.exporter.otlp.customizer import (
+    BaseOTLPExporters,
+    OTLPExporterCustomizerBase,
+)
+
+
+class GoogleOTLPExporterCustomizer(OTLPExporterCustomizerBase):
+    def __init__(self):
+        credentials, _ = google.auth.default()
+        request = requests.Request()
+        auth_metadata_plugin = AuthMetadataPlugin(
+            credentials=credentials, request=request
+        )
+
+        self.authed_session = AuthorizedSession(credentials)
+        self.channel_creds = grpc.composite_channel_credentials(
+            grpc.ssl_channel_credentials(),
+            grpc.metadata_call_credentials(auth_metadata_plugin),
+        )
+
+    def customize_exporter(
+        self, exporter_class: BaseOTLPExporters
+    ) -> Tuple[str, str]:
+        params = inspect.signature(exporter_class.__init__).parameters
+        if "credentials" in params and isinstance(
+            self.channel_creds, params["credentials"].annotation
+        ):
+            return exporter_class(credentials=self.channel_creds)
+        if "session" in params and isinstance(
+            self.authed_session, params["session"].annotation
+        ):
+            return exporter_class(session=self.authed_session)
+        raise RuntimeError(
+            "OTLP Exporter class {export_class.__name__} does not contain a parameter named `sesion` or `credentials`."
+        )
+

exportercustomizer/gcp/src/opentelemetry/auth/gcp/version.py

@@ -0,0 +1 @@
+__version__ = "0.52b0.dev"

opentelemetry-instrumentation/pyproject.toml

@@ -27,7 +27,7 @@ classifiers = [
 ]
 dependencies = [
   "opentelemetry-api ~= 1.4",
-  "opentelemetry-semantic-conventions == 0.52b0.dev",
+  "opentelemetry-semantic-conventions == 0.51b0",
   "wrapt >= 1.0.0, < 2.0.0",
   "packaging >= 18.0",
 ]

opentelemetry-instrumentation/src/opentelemetry/instrumentation/auto_instrumentation/__init__.py

@@ -115,6 +115,7 @@ def run() -> None:
     environ["PYTHONPATH"] = pathsep.join(python_path)
 
     executable = which(args.command)
+    print("running executable")
     execl(executable, executable, *args.command_args)
 
 
@@ -127,6 +128,7 @@ def initialize():
         )
 
     try:
+        print("loading distro")
         distro = _load_distro()
         distro.configure()
         _load_configurators()