feat: sink pipes for health_score and insights_projects_populated (#3592)

Author: epipav

services/libs/tinybird/pipes/health_score_sink.pipe

@@ -0,0 +1,12 @@
+NODE health_score_select_fields
+SQL >
+
+    SELECT id, segmentId, slug, if (isNaN(overallScore), null, overallScore) as overallScore, toStartOfDay(now()) as date FROM health_score_copy_ds
+
+TYPE sink
+EXPORT_SERVICE kafka
+EXPORT_CONNECTION_NAME lfx-oracle-kafka-streaming
+EXPORT_KAFKA_TOPIC health_score_sink
+EXPORT_SCHEDULE 30 0 * * *
+
+

services/libs/tinybird/pipes/insights_projects_populated_sink.pipe

@@ -0,0 +1,13 @@
+NODE insights_projects_select_fields
+SQL >
+
+    SELECT id, collectionsSlugs, name, slug, segmentId, softwareValue, toStartOfDay(now()) as date
+    FROM insights_projects_populated_ds
+
+TYPE sink
+EXPORT_SERVICE kafka
+EXPORT_CONNECTION_NAME lfx-oracle-kafka-streaming
+EXPORT_KAFKA_TOPIC insights_projects_populated_sink
+EXPORT_SCHEDULE 30 0 * * *
+
+