import sys
import pandas as pd
import json
from collections import defaultdict
from pprint import pprint
from parse_output import *
results = list(parse_output(sys.stdin))
df = as_scalability_df(results)
output = defaultdict(list) for (name, threads), data in df.groupby(['queue', 'threads']):
s = data["msg/sec"].describe(percentiles=None)
threads = int(threads)
output[name].append([threads, *[int(s[f]) for f in ['min', 'max', 'mean', 'std']]])
json.dump(output, sys.stdout)
print()