Add python script

Author: manh9203

ci/scripts/metric_unify/prometheus_flamegraph.py

@@ -0,0 +1,128 @@
+import re
+import argparse
+import os
+import sys
+import subprocess
+from prometheus_api_client import PrometheusConnect
+from utils import FLAMEGRAPHS_DIR, get_git_root
+
+def get_stack_lines(prom, group_by_kvs, stack_keys, metric_name, sum_metrics=None):
+    """
+    Filters metrics from prometheus for entries that look like:
+        [ { labels: [["key1", "span1;span2"], ["key2", "span3"]], "metric": metric_name, "value": 2 } ]
+
+    It will find entries that have all of stack_keys as present in the labels and then concatenate the corresponding values into a single flat stack entry and then add the value at the end.
+    It will write a file with one line each for flamegraph.pl or inferno-flamegraph to consume.
+    If sum_metrics is not None, instead of searching for metric_name, it will sum the values of the metrics in sum_metrics.
+    """
+    lines = []
+    stack_sums = {}
+    non_zero = False
+
+    if sum_metrics is not None:
+        regex = "|".join(re.escape(m) for m in sum_metrics)
+        promql = f'{{__name__=~"^{regex}$"}}'
+        metrics = prom.custom_query(promql)
+    else:
+        promql = f'{{__name__=~"^{metric_name}$"}}'
+        metrics = prom.custom_query(promql)
+
+    # Process metrics
+    for metric in metrics:
+        labels = metric['metric']
+        filter = False
+        for key, value in group_by_kvs:
+            if key not in labels or labels[key] != value:
+                filter = True
+                break
+        if filter:
+            continue
+
+        stack_values = []
+        for key in stack_keys:
+            if key not in labels:
+                filter = True
+                break
+            stack_values.append(labels[key])
+        if filter:
+            continue
+
+        stack = ';'.join(stack_values)
+        value = int(metric['value'][1])
+        stack_sums[stack] = stack_sums.get(stack, 0) + value
+
+        if value != 0:
+            non_zero = True
+
+    lines = [f"{stack} {value}" for stack, value in stack_sums.items() if value != 0]
+
+    # Currently cycle tracker does not use gauge
+    return lines if non_zero else []
+
+
+def create_flamegraph(fname, prom, group_by_kvs, stack_keys, metric_name, sum_metrics=None, reverse=False):
+    lines = get_stack_lines(prom, group_by_kvs, stack_keys, metric_name, sum_metrics)
+    if not lines:
+        return
+
+    suffixes = [key for key in stack_keys if key != "cycle_tracker_span"]
+
+    git_root = get_git_root()
+    flamegraph_dir = os.path.join(git_root, FLAMEGRAPHS_DIR)
+    os.makedirs(flamegraph_dir, exist_ok=True)
+
+    path_prefix = f"{flamegraph_dir}{fname}.{'.'.join(suffixes)}.{metric_name}{'.reverse' if reverse else ''}"
+    stacks_path = f"{path_prefix}.stacks"
+    flamegraph_path = f"{path_prefix}.svg"
+
+    with open(stacks_path, 'w') as f:
+        for line in lines:
+            f.write(f"{line}\n")
+
+    with open(flamegraph_path, 'w') as f:
+        command = ["inferno-flamegraph", "--title", f"{fname} {' '.join(suffixes)} {metric_name}", stacks_path]
+        if reverse:
+            command.append("--reverse")
+
+        subprocess.run(command, stdout=f, check=False)
+        print(f"Created flamegraph at {flamegraph_path}")
+
+
+def create_flamegraphs(prom, group_by, stack_keys, metric_name, sum_metrics=None, reverse=False):
+    # Assume group_by is a list of length 1
+    group_by_values_list = prom.get_label_values(label_name=group_by[0])
+    for group_by_values in group_by_values_list:
+        group_by_kvs = list(zip(group_by, [group_by_values]))
+        fname = 'metrics' + '-' + '-'.join([group_by_values])
+        create_flamegraph(fname, prom, group_by_kvs, stack_keys, metric_name, sum_metrics, reverse=reverse)
+
+
+def create_custom_flamegraphs(prom, group_by=["group"]):
+    for reverse in [False, True]:
+        create_flamegraphs(prom, group_by, ["cycle_tracker_span", "dsl_ir", "opcode"], "frequency",
+                           reverse=reverse)
+        create_flamegraphs(prom, group_by, ["cycle_tracker_span", "dsl_ir", "opcode", "air_name"], "cells_used",
+                           reverse=reverse)
+        create_flamegraphs(prom, group_by, ["cell_tracker_span"], "cells_used",
+                           sum_metrics=["simple_advice_cells", "fixed_cells", "lookup_advice_cells"],
+                           reverse=reverse)
+
+
+def main():
+    import shutil
+
+    if not shutil.which("inferno-flamegraph"):
+        print("You must have inferno-flamegraph installed to use this script.")
+        sys.exit(1)
+
+    argparser = argparse.ArgumentParser()
+    argparser.add_argument('prometheus_url', type=str, help="Path to the prometheus server")
+    args = argparser.parse_args()
+
+    prom = PrometheusConnect(url=args.prometheus_url, disable_ssl=True)
+
+    create_custom_flamegraphs(prom)
+
+
+if __name__ == '__main__':
+    main()

crates/vm/src/metrics/cycle_tracker/mod.rs

@@ -56,7 +56,7 @@ mod emit {
         pub fn increment_opcode(&self, (dsl_ir, opcode): &(Option<String>, String)) {
             let labels = [
                 ("opcode", opcode.clone()),
-                ("dsl_ir", dsl_ir.clone().unwrap_or_default()),
+                ("dsl_ir", dsl_ir.clone().unwrap_or("-".to_string())),
                 ("cycle_tracker_span", self.get_full_name()),
             ];
             counter!("frequency", &labels).increment(1u64);
@@ -73,7 +73,7 @@ mod emit {
             let labels = [
                 ("air_name", air_name.clone()),
                 ("opcode", opcode.clone()),
-                ("dsl_ir", dsl_ir.clone().unwrap_or_default()),
+                ("dsl_ir", dsl_ir.clone().unwrap_or("-".to_string())),
                 ("cycle_tracker_span", self.get_full_name()),
             ];
             counter!("cells_used", &labels).increment(trace_cells_used as u64);

crates/vm/src/metrics/mod.rs

@@ -137,15 +137,15 @@ impl VmMetrics {
 
         for ((dsl_ir, opcode), value) in self.counts.iter() {
             let labels = [
-                ("dsl_ir", dsl_ir.clone().unwrap_or_else(String::new)),
+                ("dsl_ir", dsl_ir.clone().unwrap_or("-".to_string())),
                 ("opcode", opcode.clone()),
             ];
             counter!("frequency", &labels).absolute(*value as u64);
         }
 
         for ((dsl_ir, opcode, air_name), value) in self.trace_cells.iter() {
             let labels = [
-                ("dsl_ir", dsl_ir.clone().unwrap_or_else(String::new)),
+                ("dsl_ir", dsl_ir.clone().unwrap_or("-".to_string())),
                 ("opcode", opcode.clone()),
                 ("air_name", air_name.clone()),
             ];