Bug fix for message field on Microsoft.ApplicationInsights.Message (#43060)

* Bug fix for message field on Microsoft.ApplicationInsights.Message to not export logs with empty message body

* Updated CHANGELOG

* Fixed typing

* Trigger CI/CD pipeline

Author: rads-1996

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

@@ -9,6 +9,8 @@
 ### Bugs Fixed
 - Fixes issues #42897 - TypeError in _transmit_from_storage: LocalFileBlob.get() returns None
   ([#42897](https://github.com/Azure/azure-sdk-for-python/pull/42951))
+- Fix logic for message field on Microsoft.ApplicationInsights.Message to sync with Breeze
+  ([#43060](https://github.com/Azure/azure-sdk-for-python/pull/43060))
 
 ### Other Changes
 

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

@@ -2,7 +2,7 @@
 # Licensed under the MIT License.
 import json
 import logging
-from typing import Optional, Sequence, Any
+from typing import Optional, Sequence, Any, Union
 
 from opentelemetry._logs.severity import SeverityNumber
 from opentelemetry.semconv.attributes.exception_attributes import (
@@ -63,7 +63,7 @@ def export(self, batch: Sequence[LogData], **kwargs: Any) -> LogExportResult:  #
         :return: The result of the export.
         :rtype: ~opentelemetry.sdk._logs.export.LogData
         """
-        envelopes = [self._log_to_envelope(log) for log in batch]
+        envelopes = [envelope for log in batch if (envelope := self._log_to_envelope(log)) is not None]
         try:
             result = self._transmit(envelopes)
             self._handle_transmit_from_storage(envelopes, result)
@@ -80,8 +80,10 @@ def shutdown(self) -> None:
         if self.storage:
             self.storage.close()
 
-    def _log_to_envelope(self, log_data: LogData) -> TelemetryItem:
+    def _log_to_envelope(self, log_data: LogData) -> Union[TelemetryItem, None]:
         envelope = _convert_log_to_envelope(log_data)
+        if envelope is None:
+            return None
         envelope.instrumentation_key = self._instrumentation_key
         return envelope
 
@@ -115,7 +117,7 @@ def _log_data_is_event(log_data: LogData) -> bool:
 
 
 # pylint: disable=protected-access
-def _convert_log_to_envelope(log_data: LogData) -> TelemetryItem:
+def _convert_log_to_envelope(log_data: LogData) -> Union[TelemetryItem, None]:
     log_record = log_data.log_record
     time_stamp = log_record.timestamp if log_record.timestamp is not None else log_record.observed_timestamp
     envelope = _utils._create_telemetry_item(time_stamp)
@@ -189,6 +191,9 @@ def _convert_log_to_envelope(log_data: LogData) -> TelemetryItem:
             severity_level=severity_level,  # type: ignore
             properties=properties,
         )
+        if len(data.message) == 0:
+            _logger.warning("Log record body cannot be empty. Skipping export for this log record.")
+            return None
         envelope.data = MonitorBase(base_data=data, base_type="MessageData")
 
     return envelope

sdk/monitor/azure-monitor-opentelemetry-exporter/tests/logs/test_logs.py

@@ -408,16 +408,12 @@ def test_log_to_envelope_log(self):
     def test_log_to_envelope_log_none(self):
         exporter = self._exporter
         envelope = exporter._log_to_envelope(self._log_data_none)
-        self.assertEqual(envelope.name, "Microsoft.ApplicationInsights.Message")
-        self.assertEqual(envelope.data.base_type, "MessageData")
-        self.assertEqual(envelope.data.base_data.message, "")
+        self.assertEqual(envelope, None)
 
     def test_log_to_envelope_log_empty(self):
         exporter = self._exporter
         envelope = exporter._log_to_envelope(self._log_data_empty)
-        self.assertEqual(envelope.name, "Microsoft.ApplicationInsights.Message")
-        self.assertEqual(envelope.data.base_type, "MessageData")
-        self.assertEqual(envelope.data.base_data.message, "")
+        self.assertEqual(envelope, None)
 
     def test_log_to_envelope_log_complex_body(self):
         exporter = self._exporter