Add additional logging for errors

Author: MattKotsenas

src/OpenTelemetry.Instrumentation.Kusto/Implementation/KustoInstrumentationEventSource.cs

@@ -28,4 +28,31 @@ public void EnrichmentException(string exception)
     {
         this.WriteEvent(1, exception);
     }
+
+    [Event(2, Message = "Trace record payload is NULL or has NULL message, record will not be processed.", Level = EventLevel.Warning)]
+    public void NullPayload()
+    {
+        this.WriteEvent(2);
+    }
+
+    [Event(3, Message = "Failed to find context for activity ID '{0}', operation data will not be recorded.", Level = EventLevel.Warning)]
+    public void ContextNotFound(string activityId)
+    {
+        this.WriteEvent(3, activityId);
+    }
+
+    [NonEvent]
+    public void UnknownErrorProcessingTraceRecord(Exception ex)
+    {
+        if (this.IsEnabled(EventLevel.Error, EventKeywords.All))
+        {
+            this.UnknownErrorProcessingTraceRecord(ex.ToInvariantString());
+        }
+    }
+
+    [Event(4, Message = "Unknown error processing trace record, Exception: {0}", Level = EventLevel.Error)]
+    public void UnknownErrorProcessingTraceRecord(string exception)
+    {
+        this.WriteEvent(4, exception);
+    }
 }

src/OpenTelemetry.Instrumentation.Kusto/Implementation/KustoTraceRecordListener.cs

@@ -33,6 +33,7 @@ public override void Write(KustoUtils.TraceRecord record)
     {
         if (record?.Message is null)
         {
+            KustoInstrumentationEventSource.Log.NullPayload();
             return;
         }
 
@@ -41,17 +42,24 @@ public override void Write(KustoUtils.TraceRecord record)
             return;
         }
 
-        if (record.IsRequestStart())
-        {
-            this.HandleHttpRequestStart(record);
-        }
-        else if (record.IsActivityComplete())
+        try
         {
-            this.HandleActivityComplete(record);
+            if (record.IsRequestStart())
+            {
+                this.HandleHttpRequestStart(record);
+            }
+            else if (record.IsActivityComplete())
+            {
+                this.HandleActivityComplete(record);
+            }
+            else if (record.IsException())
+            {
+                this.HandleException(record);
+            }
         }
-        else if (record.IsException())
+        catch (Exception ex)
         {
-            this.HandleException(record);
+            KustoInstrumentationEventSource.Log.UnknownErrorProcessingTraceRecord(ex);
         }
     }
 
@@ -200,6 +208,7 @@ private void HandleActivityComplete(KustoUtils.TraceRecord record)
             return context;
         }
 
+        KustoInstrumentationEventSource.Log.ContextNotFound(record.Activity.ActivityId.ToString());
         return null;
     }