add pipes

Author: alrocar

tinybird/pipes/pagerduty_incident_metrics.pipe

@@ -0,0 +1,14 @@
+TOKEN "read" READ
+TAGS "pagerduty"
+
+NODE incident_metrics
+SQL >
+    %
+    SELECT 
+        count() as total_incidents,
+        countIf(event_type = 'incident.escalated') * 100.0 / count() as escalation_rate,
+        countIf(event_type = 'incident.resolved') * 100.0 / count() as resolution_rate
+    FROM pagerduty
+    WHERE event.event.data.type::String = 'incident'
+    AND event_time >= {{DateTime(date_from, '2024-01-01 00:00:00')}}
+    AND event_time <= {{DateTime(date_to, '2024-12-31 23:59:59')}}

tinybird/pipes/pagerduty_incidents_over_time.pipe

@@ -0,0 +1,16 @@
+TOKEN "read" READ
+TAGS "pagerduty"
+
+NODE incidents_over_time
+SQL >
+    %
+    SELECT 
+        toStartOfHour(event_time) as hour,
+        event_type,
+        count() as count
+    FROM pagerduty
+    WHERE event.event.data.type::String = 'incident'
+    AND event_time >= {{DateTime(date_from, '2024-01-01 00:00:00')}}
+    AND event_time <= {{DateTime(date_to, '2024-12-31 23:59:59')}}
+    GROUP BY hour, event_type
+    ORDER BY hour DESC 

tinybird/pipes/pagerduty_resolution_times.pipe

@@ -0,0 +1,19 @@
+TOKEN "read" READ
+TAGS "pagerduty"
+
+NODE resolution_times
+SQL >
+    %
+    SELECT 
+        avg(dateDiffSeconds(
+            parseDateTimeBestEffort(event.event.data.resolved_at),
+            parseDateTimeBestEffort(event.event.data.created_at)
+        )) as avg_time_to_resolve,
+        avg(dateDiffSeconds(
+            parseDateTimeBestEffort(event.event.data.last_status_change_at),
+            parseDateTimeBestEffort(event.event.data.created_at)
+        )) as avg_time_to_last_update
+    FROM pagerduty
+    WHERE event_type = 'incident.resolved'
+    AND event_time >= {{DateTime(date_from, '2024-01-01 00:00:00')}}
+    AND event_time <= {{DateTime(date_to, '2024-12-31 23:59:59')}}

tinybird/pipes/pagerduty_responders.pipe

@@ -0,0 +1,19 @@
+TOKEN "read" READ
+TAGS "pagerduty"
+
+NODE responders
+SQL >
+    %
+    SELECT 
+        event.event.agent.summary as responder,
+        count() as responses,
+        avg(dateDiffSeconds(
+            parseDateTimeBestEffort(event.event.data.created_at),
+            parseDateTimeBestEffort(event.event.occurred_at)
+        )) as avg_response_time
+    FROM pagerduty
+    WHERE event_type = 'incident.acknowledged'
+    AND event_time >= {{DateTime(date_from, '2024-01-01 00:00:00')}}
+    AND event_time <= {{DateTime(date_to, '2024-12-31 23:59:59')}}
+    GROUP BY responder
+    ORDER BY responses DESC 

tinybird/pipes/pagerduty_service_distribution.pipe

@@ -0,0 +1,17 @@
+TOKEN "read" READ
+TAGS "pagerduty"
+
+NODE service_distribution
+SQL >
+    %
+    SELECT 
+        event.event.data.service.summary as service,
+        count() as incidents,
+        countIf(event.event.data.urgency::String = 'high') as high_urgency,
+        round(avg(event.event.data.urgency::String = 'high') * 100, 2) as high_urgency_rate
+    FROM pagerduty
+    WHERE event_type = 'incident.triggered'
+    AND event_time >= {{DateTime(date_from, '2024-01-01 00:00:00')}}
+    AND event_time <= {{DateTime(date_to, '2024-12-31 23:59:59')}}
+    GROUP BY service
+    ORDER BY incidents DESC 

tinybird/pipes/pagerduty_status_distribution.pipe

@@ -0,0 +1,16 @@
+TOKEN "read" READ
+TAGS "pagerduty"
+
+NODE status_distribution
+SQL >
+    %
+    SELECT 
+        event_type,
+        count() as count,
+        round(count() * 100.0 / sum(count()) OVER (), 2) as percentage
+    FROM pagerduty
+    WHERE event.event.data.type = 'incident'
+    AND event_time >= {{DateTime(date_from, '2024-01-01 00:00:00')}}
+    AND event_time <= {{DateTime(date_to, '2024-12-31 23:59:59')}}
+    GROUP BY event_type
+    ORDER BY count DESC