remove old bechmark stuff
This commit is contained in:
		@@ -1,61 +0,0 @@
 | 
				
			|||||||
#!/usr/bin/env python3
 | 
					 | 
				
			||||||
import csv
 | 
					 | 
				
			||||||
import os
 | 
					 | 
				
			||||||
from pprint import pprint
 | 
					 | 
				
			||||||
import numpy as np
 | 
					 | 
				
			||||||
import matplotlib.pyplot as plt
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
#Returns array of csv files in current directory
 | 
					 | 
				
			||||||
def getFiles():
 | 
					 | 
				
			||||||
    files = [f for f in os.listdir('.') if os.path.isfile(f)]
 | 
					 | 
				
			||||||
    return[ f for f in files if f.endswith('.csv') ]
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
def processFile(fname):
 | 
					 | 
				
			||||||
    with open(fname,'r') as f:
 | 
					 | 
				
			||||||
        lines=[]
 | 
					 | 
				
			||||||
        data=csv.reader(f)
 | 
					 | 
				
			||||||
        fields=next(data)
 | 
					 | 
				
			||||||
        responseCodes={}
 | 
					 | 
				
			||||||
        responsePerSec={}
 | 
					 | 
				
			||||||
        responseTimes=[]
 | 
					 | 
				
			||||||
        for row in data:
 | 
					 | 
				
			||||||
            items=zip(fields,row)
 | 
					 | 
				
			||||||
            item={}
 | 
					 | 
				
			||||||
            for(name,value) in items:
 | 
					 | 
				
			||||||
                item[name]=value.strip()
 | 
					 | 
				
			||||||
            sec=int(item['offset'].split('.')[0])
 | 
					 | 
				
			||||||
            if sec not in responsePerSec:
 | 
					 | 
				
			||||||
                responsePerSec[sec]=[]
 | 
					 | 
				
			||||||
            else:
 | 
					 | 
				
			||||||
                responsePerSec[sec].append(item['response-time'])
 | 
					 | 
				
			||||||
            code=item['status-code']
 | 
					 | 
				
			||||||
            if code not in responseCodes:
 | 
					 | 
				
			||||||
                responseCodes[code]=1
 | 
					 | 
				
			||||||
            else:
 | 
					 | 
				
			||||||
                responseCodes[code]=responseCodes[code]+1
 | 
					 | 
				
			||||||
            responseTimes.append(item['response-time'])
 | 
					 | 
				
			||||||
        if len(responseTimes)!=0:
 | 
					 | 
				
			||||||
            maxResponse=max(responseTimes)
 | 
					 | 
				
			||||||
            minResponse=min(responseTimes)
 | 
					 | 
				
			||||||
        print("Maximum response time was ",maxResponse)
 | 
					 | 
				
			||||||
        print("Minimum response time was ",minResponse)
 | 
					 | 
				
			||||||
        else:
 | 
					 | 
				
			||||||
            print("csv is empty")
 | 
					 | 
				
			||||||
        pprint(responseCodes)
 | 
					 | 
				
			||||||
        for sec in responsePerSec:
 | 
					 | 
				
			||||||
            if len(responsePerSec[sec])!=0:
 | 
					 | 
				
			||||||
                print(sec, ":")
 | 
					 | 
				
			||||||
                print("    Maximum:", max(responsePerSec[sec]))
 | 
					 | 
				
			||||||
                print("    Minimum:", min(responsePerSec[sec]))
 | 
					 | 
				
			||||||
                print("    Num of responses:", len(responsePerSec[sec]))
 | 
					 | 
				
			||||||
            else:
 | 
					 | 
				
			||||||
                print("    empty")
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
def processAllFiles():
 | 
					 | 
				
			||||||
    files=getFiles()
 | 
					 | 
				
			||||||
    for f in files:
 | 
					 | 
				
			||||||
        print("Processing ", f)
 | 
					 | 
				
			||||||
        processFile(f)
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
if __name__ == "__main__":
 | 
					 | 
				
			||||||
    processAllFiles()
 | 
					 | 
				
			||||||
@@ -1,2 +0,0 @@
 | 
				
			|||||||
numpy
 | 
					 | 
				
			||||||
matplotlib
 | 
					 | 
				
			||||||
@@ -1 +0,0 @@
 | 
				
			|||||||
 | 
					 | 
				
			||||||
@@ -1 +0,0 @@
 | 
				
			|||||||
wrk.method = "GET"
 | 
					 | 
				
			||||||
@@ -1 +0,0 @@
 | 
				
			|||||||
107107
 | 
					 | 
				
			||||||
@@ -1,26 +0,0 @@
 | 
				
			|||||||
wrk.method = "POST"
 | 
					 | 
				
			||||||
wrk.body = "107107"
 | 
					 | 
				
			||||||
done = function(summary, latency, requests)
 | 
					 | 
				
			||||||
  -- open output file
 | 
					 | 
				
			||||||
  f = io.open("result.csv", "a+")
 | 
					 | 
				
			||||||
  
 | 
					 | 
				
			||||||
  -- write below results to file
 | 
					 | 
				
			||||||
  --   minimum latency
 | 
					 | 
				
			||||||
  --   max latency
 | 
					 | 
				
			||||||
  --   mean of latency
 | 
					 | 
				
			||||||
  --   standard deviation of latency
 | 
					 | 
				
			||||||
  --   50percentile latency
 | 
					 | 
				
			||||||
  --   90percentile latency
 | 
					 | 
				
			||||||
  --   99percentile latency
 | 
					 | 
				
			||||||
  --   99.999percentile latency
 | 
					 | 
				
			||||||
  --   duration of the benchmark
 | 
					 | 
				
			||||||
  --   total requests during the benchmark
 | 
					 | 
				
			||||||
  --   total received bytes during the benchmark
 | 
					 | 
				
			||||||
  
 | 
					 | 
				
			||||||
  f:write(string.format("%f,%f,%f,%f,%f,%f,%f,%f,%d,%d,%d\n",
 | 
					 | 
				
			||||||
  latency.min, latency.max, latency.mean, latency.stdev, latency:percentile(50),
 | 
					 | 
				
			||||||
  latency:percentile(90), latency:percentile(99), latency:percentile(99.999),
 | 
					 | 
				
			||||||
  summary["duration"], summary["requests"], summary["bytes"]))
 | 
					 | 
				
			||||||
  
 | 
					 | 
				
			||||||
  f:close()
 | 
					 | 
				
			||||||
end
 | 
					 | 
				
			||||||
@@ -1,24 +0,0 @@
 | 
				
			|||||||
done = function(summary, latency, requests)
 | 
					 | 
				
			||||||
  -- open output file
 | 
					 | 
				
			||||||
  f = io.open("result.csv", "a+")
 | 
					 | 
				
			||||||
  
 | 
					 | 
				
			||||||
  -- write below results to file
 | 
					 | 
				
			||||||
  --   minimum latency
 | 
					 | 
				
			||||||
  --   max latency
 | 
					 | 
				
			||||||
  --   mean of latency
 | 
					 | 
				
			||||||
  --   standard deviation of latency
 | 
					 | 
				
			||||||
  --   50percentile latency
 | 
					 | 
				
			||||||
  --   90percentile latency
 | 
					 | 
				
			||||||
  --   99percentile latency
 | 
					 | 
				
			||||||
  --   99.999percentile latency
 | 
					 | 
				
			||||||
  --   duration of the benchmark
 | 
					 | 
				
			||||||
  --   total requests during the benchmark
 | 
					 | 
				
			||||||
  --   total received bytes during the benchmark
 | 
					 | 
				
			||||||
  
 | 
					 | 
				
			||||||
  f:write(string.format("%f,%f,%f,%f,%f,%f,%f,%f,%d,%d,%d\n",
 | 
					 | 
				
			||||||
  latency.min, latency.max, latency.mean, latency.stdev, latency:percentile(50),
 | 
					 | 
				
			||||||
  latency:percentile(90), latency:percentile(99), latency:percentile(99.999),
 | 
					 | 
				
			||||||
  summary["duration"], summary["requests"], summary["bytes"]))
 | 
					 | 
				
			||||||
  
 | 
					 | 
				
			||||||
  f:close()
 | 
					 | 
				
			||||||
end
 | 
					 | 
				
			||||||
		Reference in New Issue
	
	Block a user