Update individual.py

individual.py

+import os
+import argparse
+
+NIVELES_CARGA_PRIND = [150]
+PERIODOS_SUBIDA_PRIND = 10
+DURACION_PRIND = 420
+TIEMPO_PENSAR = 30000
+NIVELES_PENSAR = [30000]
+#Función que elimina las líneas correspondientes a medidas fuera el periodo estacionario
+def eliminarLineas(rutaEntrada, rutaSalida, numHilos):
+    ficheroEntrada = open(rutaEntrada, "r")
+
+    directorio = rutaSalida[0:rutaSalida.rfind("/")]
+
+    if not os.path.exists(directorio):
+        os.makedirs(directorio)
+
+    ficheroSalida = open(rutaSalida, "w")
+
+    #Copiar cabecera
+    linea = ficheroEntrada.readline()
+    ficheroSalida.write(linea)
+
+    while True:
+        linea = ficheroEntrada.readline()
+
+        if not linea:
+            break
+
+        columnas = linea.split(",")
+        #El número total de hilos ocupa la posición 13 en el fichero jtl
+        hilosLinea = int(columnas[12])
+        
+        if hilosLinea < numHilos:
+            continue
+        elif hilosLinea == numHilos:
+            ficheroSalida.write(linea)
+        else:
+            break
+
+def eliminarFilas(rutaEntrada, rutaSalida, numHilos):
+    ficheroEntrada = open(rutaEntrada, "r")
+
+    directorio = rutaSalida[0:rutaSalida.rfind("/")]
+
+    if not os.path.exists(directorio):
+        os.makedirs(directorio)
+
+    ficheroSalida = open(rutaSalida, "w")
+
+    linea = ficheroEntrada.readline()
+
+
+    while True:
+        linea = ficheroEntrada.readline()
+
+        if not linea:
+            break
+
+        columnas = linea.split(",")
+        #El número total de hilos ocupa la posición 13 en el fichero jtl
+        #El número total de hilos ocupa la posición 13 en el fichero jtl
+        hilosLinea = int(columnas[12])
+        if hilosLinea < numHilos:
+            continue
+        elif hilosLinea == numHilos:
+            linea2 = columnas[0]+","+columnas[1]+","+columnas[2]+","+columnas[3]+","+columnas[4]+","+columnas[5]+","+columnas[6]+","+columnas[7]+","+columnas[9]+","+columnas[10]+"\n"
+            ficheroSalida.write(linea2)
+        else:
+            break
+
+        
+        
+
+        
+
+
+def ejecutarJMeter(ficheroJMeter, nombreFichero, nombreLog, hilos, tiempoSubida, duracion,rutaAgregate):
+    os.system(
+        "jmeter -n -t " + ficheroJMeter + " -l " + nombreFichero + ".jtl -j " + nombreLog + ".log -DHILOS=" + str(hilos)
+        + " -DSUBIDA=" + str(tiempoSubida) + " -DDURACION=" + str(duracion) + " -DRUTAPERFMON=" + nombreFichero + "perf.csv"  + " -DRUTAPERFMON2="+ rutaAgregate
+        )
+
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser(description="Script para trabajo individual")
+    parser.add_argument("-p", help="Práctica(s) a ejecutar", type=int, nargs="+", metavar="P")
+    parser.add_argument("-n", help="Nivel(es) de carga a ejecutar (en caso de que haya más de uno)", type=int, nargs="+", metavar="N")
+    parser.add_argument('-r', help="Solo recortar fichero", action='store_true')
+    argumentos = parser.parse_args()
+    
+    #Practica
+    if not argumentos.p or 1 in argumentos.p:
+        for j in NIVELES_PENSAR:     
+            for i in NIVELES_CARGA_PRIND:
+            	if not argumentos.n or i in argumentos.n:
+               		hilos = i
+                	pensar= j
+                	nombreFichero = "Resultados/Originales/indiv" + str(i) + str(j)
+                	nombreFicheroEditado = "Resultados/Corregidos/indiv" + str(hilos) +str(
+                    	j) + ".jtl"
+                	nombreFicheroEditado2 = "Resultados/Corregidos/indivCov" + str(hilos) + str(
+                    	j) + ".csv"
+                	nombreFicheroEditado3 = "Resultados/Corregidos/indivCov2" + str(hilos) + str(
+                    	j) + ".csv"
+                	nombreLog = "Logs/Practica3/indiv" + str(i)
+                	rutaAgregate = "Resultados/Originales/Agregate/agreg"+str(i) +".csv"
+                	rutaAgregateEditado = "Resultados/Corregidos/Agregate/agreg"+str(i)+ ".csv"
+                	tiempoSubida = PERIODOS_SUBIDA_PRIND
+               
+                	duracion = tiempoSubida + DURACION_PRIND
+                	if not argumentos.r:                	
+                            print("===================================================================================")
+                            print("Ejecutando práctica individual tiempo de pensar " + str(hilos)+str(j) + " milisegundos...")
+                            print("===================================================================================\n\n")
+
+                            ejecutarJMeter("individual.jmx", nombreFichero, nombreLog, hilos, tiempoSubida, duracion,rutaAgregate)
+
+                            print("\n\n===================================================================================")
+                            print("Terminada ejecución práctica individual tiempo de pensar " + str(hilos) + str(j)+" milisegundos")
+                            print("===================================================================================\n")
+	
+                	print("===================================================================================")
+                	print("Eliminando periodo de subida del resultado...")
+                	print("===================================================================================\n")
+
+                	eliminarLineas(nombreFichero + ".jtl", nombreFicheroEditado,hilos)
+                	eliminarFilas(nombreFichero + ".jtl", nombreFicheroEditado2,hilos)
+
+                	print("===================================================================================")
+                	print("Eliminado periodo de subida del resultado...")
+                	print("===================================================================================\n")