Integration Exception Tracking

Add count

ddtrace/internal/logger.py

@@ -218,7 +218,7 @@ def _report_telemetry_log(self, record):
                     # TODO redact absolute file paths and unknown packages
             if record.levelno >= logging.ERROR or stack_trace is not None:
                 # Report only an error or an exception with a stack trace
-                telemetry.telemetry_writer.add_log(level, record.msg, tags=tags, stack_trace=stack_trace)
+                telemetry.telemetry_writer.add_log(level, record.msg, tags=tags, stack_trace=stack_trace, count=key_bucket.skipped + 1)
 
 
 class _TelemetryConfig:

ddtrace/internal/telemetry/writer.py

@@ -478,8 +478,8 @@ def add_configurations(self, configuration_list):
                     "value": value,
                 }
 
-    def add_log(self, level, message, stack_trace="", tags=None):
-        # type: (TELEMETRY_LOG_LEVEL, str, str, Optional[Dict]) -> None
+    def add_log(self, level, message, stack_trace="", tags=None, count=1):
+        # type: (TELEMETRY_LOG_LEVEL, str, str, Optional[Dict], int) -> None
         """
         Queues log. This event is meant to send library logs to Datadog’s backend through the Telemetry intake.
         This will make support cycles easier and ensure we know about potentially silent issues in libraries.
@@ -499,6 +499,8 @@ def add_log(self, level, message, stack_trace="", tags=None):
                 data["tags"] = ",".join(["%s:%s" % (k, str(v).lower()) for k, v in tags.items()])
             if stack_trace:
                 data["stack_trace"] = stack_trace
+            if count > 1:
+                data["count"] = count
             self._logs.add(data)
 
     def add_gauge_metric(self, namespace, name, value, tags=None):