Add EventBridge rule target analytics (#11884)

joe4dev · web-flow · commit ad1af78dac88 · 2024-11-20T20:25:16.000+01:00
diff --git a/localstack-core/localstack/services/events/provider.py b/localstack-core/localstack/services/events/provider.py
@@ -145,6 +145,7 @@
     TargetSenderDict,
     TargetSenderFactory,
 )
+from localstack.services.events.usage import rule_error, rule_invocation
 from localstack.services.events.utils import (
     extract_event_bus_name,
     extract_region_and_account_id,
@@ -1334,7 +1335,6 @@ def put_events(
                 f"1 validation error detected: Value '{formatted_entries}' at 'entries' failed to satisfy constraint: Member must have length less than or equal to 10"
             )
         entries, failed_entry_count = self._process_entries(context, entries)
-
         response = PutEventsResponse(
             Entries=entries,
             FailedEntryCount=failed_entry_count,
@@ -2035,7 +2035,9 @@ def _process_rules(
                     try:
                         target_sender.process_event(event_formatted.copy())
                         processed_entries.append({"EventId": event_formatted["id"]})
+                        rule_invocation.record(target_sender.service)
                     except Exception as error:
+                        rule_error.record(target_sender.service)
                         processed_entries.append(
                             {
                                 "ErrorCode": "InternalException",
diff --git a/localstack-core/localstack/services/events/usage.py b/localstack-core/localstack/services/events/usage.py
@@ -0,0 +1,7 @@
+from localstack.utils.analytics.usage import UsageSetCounter
+
+# number of pipe invocations per source (e.g. aws:sqs, aws:kafka, SelfManagedKafka) and target (e.g., aws:lambda)
+rule_invocation = UsageSetCounter("events:rule:invocation")
+
+# number of pipe errors per source (e.g. aws:sqs, aws:kafka, SelfManagedKafka) and target (e.g., aws:lambda)
+rule_error = UsageSetCounter("events:rule:error")
