diff --git a/services/libs/tinybird/pipes/health_score_sink.pipe b/services/libs/tinybird/pipes/health_score_sink.pipe
new file mode 100644
index 0000000000..8eebc69835
--- /dev/null
+++ b/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 * * *
+
+
diff --git a/services/libs/tinybird/pipes/insights_projects_populated_sink.pipe b/services/libs/tinybird/pipes/insights_projects_populated_sink.pipe
new file mode 100644
index 0000000000..67a9cfecc5
--- /dev/null
+++ b/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 * * *
+
+