2020-03-25 09:21:57 +01:00
|
|
|
#!/usr/bin/env python3
|
|
|
|
import matplotlib
|
|
|
|
matplotlib.use('Agg')
|
|
|
|
import matplotlib.pyplot as plt
|
|
|
|
import matplotlib.pyplot as plt2
|
|
|
|
import numpy as np
|
|
|
|
import csv
|
|
|
|
import sys
|
|
|
|
from scipy import *
|
|
|
|
|
|
|
|
csvfile = sys.argv[1]
|
|
|
|
Plotfilename = sys.argv[2]
|
|
|
|
|
|
|
|
x = []
|
|
|
|
y = []
|
|
|
|
db = []
|
|
|
|
kafka = []
|
|
|
|
id = []
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
with open(csvfile) as csvfile:
|
|
|
|
tpcdata = csv.reader(csvfile, delimiter=';')
|
|
|
|
for row in tpcdata:
|
|
|
|
db.append(int(row[1]))
|
|
|
|
kafka.append(int(row[0]))
|
|
|
|
id.append(int(row[3]))
|
|
|
|
|
|
|
|
xmin=0
|
|
|
|
xmax=len(id)
|
|
|
|
ymin=0
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
x = []
|
|
|
|
y = []
|
|
|
|
|
|
|
|
for i in range(xmin,xmax):
|
|
|
|
y.append((kafka[i] - db[i]) / 1000)
|
|
|
|
x.append(id[i])
|
|
|
|
ymax=max(y)
|
|
|
|
plt.subplot(3, 1, 1)
|
|
|
|
plt.plot(x,y)
|
|
|
|
plt.xlabel('millisecond')
|
2020-06-16 11:55:21 +02:00
|
|
|
plt.ylabel('delta insert database to topic')
|
2020-03-25 09:21:57 +01:00
|
|
|
plt.title('TPC Graph\nInsert data')
|
|
|
|
plt.legend()
|
|
|
|
axes = plt.gca()
|
|
|
|
axes.set_xlim([xmin,xmax])
|
|
|
|
axes.set_ylim([ymin,ymax])
|
|
|
|
|
2020-06-16 11:55:21 +02:00
|
|
|
print('delta insert database to topic')
|
2020-03-25 09:21:57 +01:00
|
|
|
print('min :',min(y))
|
|
|
|
print('max :',max(y))
|
|
|
|
print('average :',sum(y)/len(y))
|
|
|
|
print('std :',std(y))
|
|
|
|
|
|
|
|
|
|
|
|
x = []
|
|
|
|
y = []
|
|
|
|
for i in range(xmin,xmax):
|
|
|
|
y.append(db[i])
|
|
|
|
divy = min(y)
|
|
|
|
y=[]
|
|
|
|
for i in range(xmin,xmax):
|
|
|
|
y.append((db[i] - divy) / 1000)
|
|
|
|
divy=db[i]
|
|
|
|
x.append(id[i])
|
|
|
|
|
|
|
|
ymax=max(y)
|
|
|
|
plt.subplot(3, 1, 2)
|
|
|
|
plt.plot(x,y)
|
|
|
|
plt.xlabel('entires')
|
|
|
|
plt.ylabel('delta ')
|
|
|
|
plt.title('')
|
|
|
|
plt.legend()
|
|
|
|
axes = plt.gca()
|
|
|
|
axes.set_xlim([xmin,xmax])
|
|
|
|
axes.set_ylim([ymin,40])
|
|
|
|
|
2020-06-16 11:55:21 +02:00
|
|
|
print('database in ')
|
2020-03-25 09:21:57 +01:00
|
|
|
print('min :',min(y))
|
|
|
|
print('max :',max(y))
|
|
|
|
print('average :',sum(y)/len(y))
|
|
|
|
print('std :',std(y))
|
|
|
|
|
|
|
|
x = []
|
|
|
|
y = []
|
|
|
|
for i in range(xmin,xmax):
|
|
|
|
y.append(kafka[i])
|
|
|
|
divy = min(y)
|
|
|
|
y=[]
|
|
|
|
for i in range(xmin,xmax):
|
|
|
|
y.append((kafka[i] - divy) / 1000)
|
|
|
|
divy=kafka[i]
|
|
|
|
x.append(id[i])
|
|
|
|
|
|
|
|
ymax=max(y)
|
|
|
|
plt.subplot(3, 1, 3)
|
|
|
|
plt.plot(x,y)
|
|
|
|
plt.xlabel('entires')
|
|
|
|
plt.ylabel('delta ')
|
|
|
|
plt.title('')
|
|
|
|
plt.legend()
|
|
|
|
axes = plt.gca()
|
|
|
|
axes.set_xlim([xmin,xmax])
|
|
|
|
|
|
|
|
print('kafka in')
|
|
|
|
print('min :',min(y))
|
|
|
|
print('max :',max(y))
|
|
|
|
print('average :',sum(y)/len(y))
|
|
|
|
print('std :',std(y))
|
|
|
|
|
|
|
|
|
|
|
|
plt.savefig(Plotfilename)
|