Also add is_lambda support to AwsCloudWatchEmfExporter

- Update AwsCloudWatchEmfExporter to accept and pass is_lambda parameter
- Use _is_lambda_environment() for both ConsoleEmfExporter and
  AwsCloudWatchEmfExporter in _create_emf_exporter()
- Add unit test for is_lambda initialization in AwsCloudWatchEmfExporter

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <[email protected]>

Author: syed-ahsan-ishtiaque

aws-opentelemetry-distro/src/amazon/opentelemetry/distro/aws_opentelemetry_configurator.py

@@ -835,7 +835,7 @@ def _create_emf_exporter():
             # pylint: disable=import-outside-toplevel
             from amazon.opentelemetry.distro.exporter.aws.metrics.console_emf_exporter import ConsoleEmfExporter
 
-            return ConsoleEmfExporter(namespace=log_header_setting.namespace, is_lambda=True)
+            return ConsoleEmfExporter(namespace=log_header_setting.namespace, is_lambda=_is_lambda_environment())
 
         # For non-Lambda environment or Lambda with valid headers - use CloudWatch EMF exporter
         session = get_aws_session()
@@ -857,6 +857,7 @@ def _create_emf_exporter():
             namespace=log_header_setting.namespace,
             log_group_name=log_header_setting.log_group,
             log_stream_name=log_header_setting.log_stream,
+            is_lambda=_is_lambda_environment(),
         )
     # pylint: disable=broad-exception-caught
     except Exception as errors:

aws-opentelemetry-distro/src/amazon/opentelemetry/distro/exporter/aws/metrics/aws_cloudwatch_emf_exporter.py

@@ -34,6 +34,7 @@ def __init__(
         aws_region: Optional[str] = None,
         preferred_temporality: Optional[Dict[type, AggregationTemporality]] = None,
         preferred_aggregation: Optional[Dict[type, Any]] = None,
+        is_lambda: bool = False,
         **kwargs,
     ):
         """
@@ -46,9 +47,10 @@ def __init__(
             aws_region: AWS region (auto-detected if None)
             preferred_temporality: Optional dictionary mapping instrument types to aggregation temporality
             preferred_aggregation: Optional dictionary mapping instrument types to preferred aggregation
+            is_lambda: Whether the exporter is running in AWS Lambda environment
             **kwargs: Additional arguments passed to botocore client
         """
-        super().__init__(namespace, preferred_temporality, preferred_aggregation)
+        super().__init__(namespace, preferred_temporality, preferred_aggregation, is_lambda=is_lambda)
 
         self.log_group_name = log_group_name
 

aws-opentelemetry-distro/tests/amazon/opentelemetry/distro/exporter/aws/metrics/test_aws_cloudwatch_emf_exporter.py

@@ -161,6 +161,32 @@ def test_initialization_with_custom_params(self, mock_session):
         self.assertEqual(exporter.namespace, "CustomNamespace")
         self.assertEqual(exporter.log_group_name, "custom-log-group")
 
+    @patch("botocore.session.Session")
+    def test_is_lambda_initialization(self, mock_session):
+        """Test exporter initialization with is_lambda parameter."""
+        # Mock the botocore session to avoid AWS calls
+        mock_client = Mock()
+        mock_session_instance = Mock()
+        mock_session.return_value = mock_session_instance
+        mock_session_instance.create_client.return_value = mock_client
+
+        # Test with is_lambda=True
+        exporter_lambda = AwsCloudWatchEmfExporter(
+            session=mock_session_instance,
+            namespace="TestNamespace",
+            log_group_name="test-log-group",
+            is_lambda=True,
+        )
+        self.assertTrue(exporter_lambda._is_lambda)
+
+        # Test with is_lambda=False (default)
+        exporter_non_lambda = AwsCloudWatchEmfExporter(
+            session=mock_session_instance,
+            namespace="TestNamespace",
+            log_group_name="test-log-group",
+        )
+        self.assertFalse(exporter_non_lambda._is_lambda)
+
     def test_get_unit_mapping(self):
         """Test unit mapping functionality."""
         # Test known units from UNIT_MAPPING