Modularize fetching appid logic and fix format

Author: rads-1996

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_connection_string_parser.py

@@ -9,7 +9,7 @@
 INSTRUMENTATION_KEY = "instrumentationkey"
 # cspell:disable-next-line
 AAD_AUDIENCE = "aadaudience"
-APPLICATION_ID = "applicationid"
+APPLICATION_ID = "applicationid" # cspell:disable-line
 
 # Validate UUID format
 # Specs taken from https://tools.ietf.org/html/rfc4122

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_utils.py

@@ -20,6 +20,7 @@
 from azure.core.pipeline.policies import BearerTokenCredentialPolicy
 from azure.monitor.opentelemetry.exporter._generated.models import ContextTagKeys, TelemetryItem
 from azure.monitor.opentelemetry.exporter._version import VERSION as ext_version
+from azure.monitor.opentelemetry.exporter._connection_string_parser import ConnectionStringParser
 from azure.monitor.opentelemetry.exporter._constants import (
     _AKS_ARM_NAMESPACE_ID,
     _DEFAULT_AAD_SCOPE,
@@ -431,3 +432,7 @@ def get_compute_type():
 
 def _get_sha256_hash(input_str: str) -> str:
     return hashlib.sha256(input_str.encode("utf-8")).hexdigest()
+
+def _get_application_id(connection_string: Optional[str]) -> Optional[str]:
+    parsed_connection_string = ConnectionStringParser(connection_string)
+    return parsed_connection_string.application_id

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/export/trace/_exporter.py

@@ -34,7 +34,6 @@
     _APPLICATION_ID_RESOURCE_KEY,
 )
 from azure.monitor.opentelemetry.exporter import _utils
-from azure.monitor.opentelemetry.exporter._connection_string_parser import ConnectionStringParser
 from azure.monitor.opentelemetry.exporter._generated.models import (
     ContextTagKeys,
     MessageData,
@@ -108,6 +107,7 @@ class AzureMonitorTraceExporter(BaseExporter, SpanExporter):
     def __init__(self, **kwargs: Any):
         self._tracer_provider = kwargs.pop("tracer_provider", None)
         super().__init__(**kwargs)
+        self.application_id = _utils._get_application_id(self._connection_string)
 
     def export(
         self, spans: Sequence[ReadableSpan], **kwargs: Any  # pylint: disable=unused-argument
@@ -120,15 +120,13 @@ def export(
         :rtype: ~opentelemetry.sdk.trace.export.SpanExportResult
         """
         envelopes = []
-        parsed_connection_string = ConnectionStringParser(self._connection_string)
-        application_id = parsed_connection_string.application_id
 
         if spans and self._should_collect_otel_resource_metric():
             resource = None
             try:
                 tracer_provider = self._tracer_provider or get_tracer_provider()
                 resource = tracer_provider.resource  # type: ignore
-                envelopes.append(self._get_otel_resource_envelope(resource, application_id))
+                envelopes.append(self._get_otel_resource_envelope(resource, self.application_id))
             except AttributeError as e:
                 _logger.exception("Failed to derive Resource from Tracer Provider: %s", e)  # pylint: disable=C4769
         for span in spans: