add pipes

Author: alrocar

tinybird/pipes/vercel_cache_stats.pipe

@@ -10,7 +10,7 @@ SQL >
         countIf(event.proxy.vercelCache = 'HIT') as cache_hits,
         round(countIf(event.proxy.vercelCache = 'HIT') * 100.0 / count(), 2) as hit_rate
     FROM vercel_logs
-    WHERE event.proxy.vercelCache != ''
+    WHERE event.proxy.vercelCache::String != ''
     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

tinybird/pipes/vercel_errors.pipe

@@ -10,7 +10,7 @@ SQL >
         count() as total_requests,
         round(countIf(event.proxy.statusCode >= 400) * 100.0 / count(), 2) as error_rate
     FROM vercel_logs
-    WHERE event.proxy.statusCode != 0
+    WHERE event.proxy.statusCode::Int32 != 0
     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

tinybird/pipes/vercel_requests_by_status.pipe

@@ -9,7 +9,7 @@ SQL >
         count() as count,
         round(count() * 100.0 / sum(count()) OVER (), 2) as percentage
     FROM vercel_logs
-    WHERE event.proxy.statusCode != 0
+    WHERE event.proxy.statusCode::Int32 != 0
     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 status

tinybird/pipes/vercel_response_times.pipe

@@ -17,7 +17,7 @@ SQL >
             extractAll(event.message, 'Duration: ([0-9]+) ms')[1] as duration
         FROM vercel_logs
         WHERE event_type = 'stdout'
-        AND event.message LIKE '%Duration:%'
+        AND event.message::String LIKE '%Duration:%'
         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/vercel_top_paths.pipe

@@ -10,7 +10,7 @@ SQL >
         round(avg(if(event.proxy.statusCode >= 400, 1, 0)) * 100, 2) as error_rate,
         round(avg(if(event.proxy.vercelCache = 'HIT', 1, 0)) * 100, 2) as cache_hit_rate
     FROM vercel_logs
-    WHERE event.proxy.path != ''
+    WHERE event.proxy.path::String != ''
     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 path