in report/script/gen_jtl_data.py [0:0]
def gen_all(input_file_name,res_json):
mysql_file_name = '{}/{}'.format(input_file_name, "mysql_all.jtl")
sharding_proxy_file_name = '{}/{}'.format(input_file_name, "sharding-proxy_all.jtl")
sharding_jdbc_file_name = '{}/{}'.format(input_file_name, "sharding-jdbc_all.jtl")
with open(sharding_proxy_file_name) as f:
for line in f:
line = line.strip("\n")
if line != "":
res_json['INSERT+UPDATE+DELETE'][0]['data'].append(json.loads(line))
with open(sharding_jdbc_file_name) as f:
for line in f:
line = line.strip("\n")
if line != "":
res_json['INSERT+UPDATE+DELETE'][1]['data'].append(json.loads(line))
with open(mysql_file_name) as f:
for line in f:
line = line.strip("\n")
if line != "":
res_json['INSERT+UPDATE+DELETE'][2]['data'].append(json.loads(line))