feat: add sink dashboard metrics (CM-811)

services/libs/tinybird/pipes/cdp_dashboard_metrics_sink.pipe

@@ -0,0 +1,47 @@
+DESCRIPTION >
+    Global metrics for activities, organizations, and members used for CDP dashboard.
+
+NODE activityRelations_metrics
+SQL >
+    SELECT
+        count() AS activities_total,
+        countIf(createdAt >= now() - INTERVAL 30 DAY) AS activities_last_30_days
+    FROM activityRelations_deduplicated_ds
+
+NODE organizations_metrics
+SQL >
+    SELECT
+        count() AS organizations_total,
+        countIf(createdAt >= now() - INTERVAL 30 DAY) AS organizations_last_30_days
+    FROM organizations FINAL
+
+NODE members_metrics
+SQL >
+    SELECT
+        count() AS members_total, countIf(joinedAt >= now() - INTERVAL 30 DAY) AS members_last_30_days
+    FROM members FINAL
+
+NODE merge_results
+SQL >
+    SELECT
+        -- activity
+        (SELECT activities_total FROM activityRelations_metrics) AS activities_total,
+        (SELECT activities_last_30_days FROM activityRelations_metrics) AS activities_last_30_days,
+        -- organizations
+        (SELECT organizations_total FROM organizations_metrics) AS organizations_total,
+        (SELECT organizations_last_30_days FROM organizations_metrics) AS organizations_last_30_days,
+        -- members
+        (SELECT members_total FROM members_metrics) AS members_total,
+        (SELECT members_last_30_days FROM members_metrics) AS members_last_30_days
+
+NODE cdp_dashboard_full_metrics
+SQL >
+    SELECT * FROM merge_results
+
+TYPE SINK
+EXPORT_SERVICE kafka
+EXPORT_CONNECTION_NAME lfx-oracle-kafka-streaming
+EXPORT_SCHEDULE 30 0 * * *
+EXPORT_FORMAT csv
+EXPORT_STRATEGY @new
+EXPORT_KAFKA_TOPIC cdp_dashboard_metrics_sink