Using events API to emit events (#43711)

* Using events API to emit events

* Fixing linting issues

Author: singankit

sdk/evaluation/azure-ai-evaluation/azure/ai/evaluation/_evaluate/_evaluate.py

@@ -1109,19 +1109,18 @@ def _build_internal_log_attributes(
 
 
 def _log_events_to_app_insights(
-    otel_logger,
+    event_logger,
     events: List[Dict[str, Any]],
     log_attributes: Dict[str, Any],
     app_insights_config: AppInsightsConfig,
     data_source_item: Optional[Dict[str, Any]] = None,
     evaluator_config: Optional[Dict[str, EvaluatorConfig]] = None,
 ) -> None:
     """
-    Log independent events directly to App Insights using OpenTelemetry logging.
-    No spans are created - events are sent as pure log records.
+    Log independent events directly to App Insights using OpenTelemetry event logging.
 
-    :param otel_logger: OpenTelemetry logger instance
-    :type otel_logger: Logger
+    :param event_logger: OpenTelemetry event logger instance
+    :type event_logger: EventLogger
     :param events: List of event data dictionaries to log
     :type events: List[Dict[str, Any]]
     :param log_attributes: Attributes dict to use for each event (already includes extra_attributes if present)
@@ -1132,8 +1131,7 @@ def _log_events_to_app_insights(
     :type data_source_item: Optional[Dict[str, Any]]
     """
 
-    from opentelemetry import trace
-    from opentelemetry.trace import SpanContext, TraceFlags, NonRecordingSpan
+    from opentelemetry._events import Event
 
     try:
         # Initialize values from AppInsights config as defaults
@@ -1179,6 +1177,7 @@ def _log_events_to_app_insights(
                 # The standard attributes are already in https://github.com/open-telemetry/semantic-conventions/blob/main/docs/gen-ai/gen-ai-events.md#event-eventgen_aievaluationresult
                 metric_name = event_data.get("metric")
                 standard_log_attributes = {}
+                # This attributes makes evaluation events to go into customEvents table in App Insights
                 standard_log_attributes["microsoft.custom_event.name"] = EVALUATION_EVENT_NAME
                 standard_log_attributes["gen_ai.evaluation.name"] = metric_name
                 if event_data.get("score") is not None:
@@ -1241,24 +1240,14 @@ def _log_events_to_app_insights(
                 # Anonymize IP address to prevent Azure GeoIP enrichment and location tracking
                 standard_log_attributes["http.client_ip"] = "0.0.0.0"
 
-                # Create context with trace_id and span_id if present (for distributed tracing correlation)
-                ctx = None
-                if trace_id:
-                    span_context = SpanContext(
-                        trace_id=trace_id,
-                        span_id=span_id if span_id else 0,  # Use extracted span_id or 0 if not available
-                        is_remote=False,
-                        trace_flags=TraceFlags(0x01),
+                event_logger.emit(
+                    Event(
+                        name=EVALUATION_EVENT_NAME,
+                        attributes=standard_log_attributes,
+                        body=EVALUATION_EVENT_NAME,
+                        trace_id=trace_id if trace_id is not None else None,
+                        span_id=span_id if span_id is not None else None,
                     )
-                    span = NonRecordingSpan(span_context)
-                    ctx = trace.set_span_in_context(span)
-
-                otel_logger.emit(
-                    timestamp=time.time_ns(),
-                    observed_timestamp=time.time_ns(),
-                    body=EVALUATION_EVENT_NAME,
-                    attributes=standard_log_attributes,
-                    context=ctx,
                 )
 
             except Exception as e:
@@ -1289,6 +1278,8 @@ def emit_eval_result_events_to_app_insights(
     from opentelemetry.sdk.resources import Resource
     from opentelemetry.semconv.resource import ResourceAttributes
     from azure.monitor.opentelemetry.exporter import AzureMonitorLogExporter
+    from opentelemetry._events import get_event_logger
+    from opentelemetry.sdk._events import EventLoggerProvider
 
     if not results:
         LOGGER.debug("No results to log to App Insights")
@@ -1316,9 +1307,9 @@ def emit_eval_result_events_to_app_insights(
         # Add the Azure Monitor exporter to the logger provider
         logger_provider.add_log_record_processor(BatchLogRecordProcessor(azure_log_exporter))
 
-        # Create a logger from OUR configured logger_provider (not the global one)
-        # This ensures the logger uses our anonymized resource
-        otel_logger = logger_provider.get_logger(__name__)
+        # Create event logger
+        event_provider = EventLoggerProvider(logger_provider)
+        event_logger = get_event_logger(__name__, event_logger_provider=event_provider)
 
         # Initialize base log attributes with extra_attributes if present, otherwise empty dict
         base_log_attributes = app_insights_config.get("extra_attributes", {})
@@ -1338,7 +1329,7 @@ def emit_eval_result_events_to_app_insights(
             log_attributes = base_log_attributes.copy()
 
             _log_events_to_app_insights(
-                otel_logger=otel_logger,
+                event_logger=event_logger,
                 events=result["results"],
                 log_attributes=log_attributes,
                 data_source_item=result["datasource_item"] if "datasource_item" in result else None,