Implement APPLICATIONINSIGHTS_METRICS_TO_LOGANALYTICS_ENABLED env var for AKS Attach. Rebase and Squash (#41383)

Author: jeremydvoss

sdk/monitor/azure-monitor-opentelemetry-exporter/CHANGELOG.md

@@ -6,6 +6,8 @@
 
 - Add AMW deduplicating flag, SentToAMW, for AKS Attach
   ([#41410](https://github.com/Azure/azure-sdk-for-python/pull/41410))
+- Implement APPLICATIONINSIGHTS_METRICS_TO_LOGANALYTICS_ENABLED env var for AKS Attach .
+  ([#41383](https://github.com/Azure/azure-sdk-for-python/pull/41383))
 
 ### Breaking Changes
 

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

@@ -15,6 +15,7 @@
     "APPLICATIONINSIGHTS_OPENTELEMETRY_RESOURCE_METRIC_DISABLED"
 )
 _APPLICATIONINSIGHTS_METRIC_NAMESPACE_OPT_IN = "APPLICATIONINSIGHTS_METRIC_NAMESPACE_OPT_IN"
+_APPLICATIONINSIGHTS_METRICS_TO_LOGANALYTICS_ENABLED = "APPLICATIONINSIGHTS_METRICS_TO_LOGANALYTICS_ENABLED"
 _APPLICATIONINSIGHTS_AUTHENTICATION_STRING = "APPLICATIONINSIGHTS_AUTHENTICATION_STRING"
 
 # RPs

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

@@ -36,6 +36,7 @@
 from opentelemetry.semconv.trace import SpanAttributes
 
 from azure.monitor.opentelemetry.exporter._constants import (
+    _APPLICATIONINSIGHTS_METRICS_TO_LOGANALYTICS_ENABLED,
     _APPLICATIONINSIGHTS_METRIC_NAMESPACE_OPT_IN,
     _AUTOCOLLECTED_INSTRUMENT_NAMES,
     _METRIC_ENVELOPE_NAME,
@@ -80,6 +81,7 @@ def __init__(self, **kwargs: Any) -> None:
             preferred_temporality=APPLICATION_INSIGHTS_METRIC_TEMPORALITIES,  # type: ignore
             preferred_aggregation=kwargs.get("preferred_aggregation"),  # type: ignore
         )
+        self._metrics_to_log_analytics = self._determine_metrics_to_log_analytics()
 
     # pylint: disable=R1702
     def export(
@@ -152,6 +154,9 @@ def _point_to_envelope(
         resource: Optional[Resource] = None,
         scope: Optional[InstrumentationScope] = None,
     ) -> Optional[TelemetryItem]:
+        # When Metrics to Log Analytics is disabled, only send Standard metrics and _OTELRESOURCE_
+        if not self._metrics_to_log_analytics and name not in _AUTOCOLLECTED_INSTRUMENT_NAMES:
+            return None
         envelope = _convert_point_to_envelope(point, name, resource, scope)
         if name in _AUTOCOLLECTED_INSTRUMENT_NAMES:
             envelope = _handle_std_metric_envelope(envelope, name, point.attributes)  # type: ignore
@@ -169,6 +174,22 @@ def _point_to_envelope(
 
         return envelope
 
+    # pylint: disable=protected-access
+    def _determine_metrics_to_log_analytics(self) -> bool:
+        """
+        Determines whether metrics should be sent to Log Analytics.
+
+        :return: False if metrics should not be sent to Log Analytics, True otherwise.
+        :rtype: bool
+        """
+        # Disabling metrics to Log Analytics via env var is currently only specified for AKS Attach scenarios.
+        if not _utils._is_on_aks() or not _utils._is_attach_enabled() or self._is_stats_exporter():
+            return True
+        env_var = os.environ.get(_APPLICATIONINSIGHTS_METRICS_TO_LOGANALYTICS_ENABLED)
+        if not env_var:
+            return True
+        return env_var.lower().strip() != "false"
+
     # pylint: disable=docstring-keyword-should-match-keyword-only
     @classmethod
     def from_connection_string(cls, conn_str: str, **kwargs: Any) -> "AzureMonitorMetricExporter":