feat(observability): add job level streaming cpu profilling

grafana/dashboard/dev/streaming.py

@@ -1,6 +1,13 @@
 from ..common import *
 from . import section
 
+def _sum_fragment_metric_by_mv(expr: str) -> str:
+    return (
+        f"sum(({expr})"
+        f"* on(fragment_id) group_left(materialized_view_id)"
+        f"max by (fragment_id, materialized_view_id) ({metric('table_info')}))"
+        f"by (materialized_view_id)"
+    )
 
 @section
 def _(outer_panels: Panels):
@@ -9,6 +16,21 @@ def _(outer_panels: Panels):
         outer_panels.row_collapsed(
             "Streaming (Source/Sink/Materialized View/Barrier)",
             [
+                panels.subheader("General"),
+                panels.timeseries_percentage(
+                    "CPU Usage Per Materialized View",
+                    "The figure shows the CPU usage of each materialized view",
+                    [
+                        panels.target(
+                            f"{_sum_fragment_metric_by_mv(f'sum(rate({metric('stream_actor_poll_duration')}[$__rate_interval])) by (fragment_id)')}"
+                            f"/ on(materialized_view_id)"
+                            f"{_sum_fragment_metric_by_mv(f'sum({metric('stream_actor_count')}) by (fragment_id)')}"
+                            f"/ 1000000000",
+                            "materialized_view {{materialized_view_id}}",
+                        )
+                    ],
+                ),
+
                 panels.subheader("Source"),
                 panels.timeseries_rowsps(
                     "Source Throughput(rows/s)",