Changed layout of results files for round 3 and 4 so taht we can have better reporting

benchmarker.py

@@ -175,18 +175,11 @@ class Benchmarker:
   ############################################################
   # report_results
   ############################################################
-  def report_results(self, framework, test, results, latency, requests, total_time, errors, total_requests):
+  def report_results(self, framework, test, results):
     if test not in self.results['rawData'].keys():
       self.results['rawData'][test] = dict()
-      self.results['weighttpData'][test] = dict()
 
     self.results['rawData'][test][framework.sort] = results
-    self.results['weighttpData'][test][framework.sort] = dict()
-    self.results['weighttpData'][test][framework.sort]['latency'] = latency
-    self.results['weighttpData'][test][framework.sort]['requests'] = requests
-    self.results['weighttpData'][test][framework.sort]['totalTime'] = total_time
-    self.results['weighttpData'][test][framework.sort]['errors'] = errors
-    self.results['weighttpData'][test][framework.sort]['totalRequests'] = total_requests
 
   ############################################################
   # End report_results
@@ -516,12 +509,6 @@ class Benchmarker:
       self.results['rawData']['query'] = dict()
       self.results['rawData']['fortune'] = dict()
       self.results['rawData']['update'] = dict()
-      self.results['weighttpData'] = dict()
-      self.results['weighttpData']['json'] = dict()
-      self.results['weighttpData']['db'] = dict()
-      self.results['weighttpData']['query'] = dict()
-      self.results['weighttpData']['fortune'] = dict()
-      self.results['weighttpData']['update'] = dict()
     else:
       #for x in self.__gather_tests():
       #  if x.name not in self.results['frameworks']:

framework_test.py

@@ -203,8 +203,7 @@ class FrameworkTest:
         remote_script = self.__generate_concurrency_script(self.json_url, self.port)
         self.__run_benchmark(remote_script, self.benchmarker.output_file(self.name, 'json'))
         results = self.__parse_test('json')
-        self.benchmarker.report_results(framework=self, test="json", requests=results['requests'], latency=results['latency'],
-          results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+        self.benchmarker.report_results(framework=self, test="json", results=results['results'])
 
         print "Complete"
     except AttributeError:
@@ -217,8 +216,7 @@ class FrameworkTest:
         remote_script = self.__generate_concurrency_script(self.db_url, self.port)
         self.__run_benchmark(remote_script, self.benchmarker.output_file(self.name, 'db'))
         results = self.__parse_test('db')
-        self.benchmarker.report_results(framework=self, test="db", requests=results['requests'], latency=results['latency'],
-          results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+        self.benchmarker.report_results(framework=self, test="db", results=results['results'])
 
         print "Complete"
     except AttributeError:
@@ -231,8 +229,7 @@ class FrameworkTest:
         remote_script = self.__generate_query_script(self.query_url, self.port)
         self.__run_benchmark(remote_script, self.benchmarker.output_file(self.name, 'query'))
         results = self.__parse_test('query')
-        self.benchmarker.report_results(framework=self, test="query", requests=results['requests'], latency=results['latency'],
-          results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+        self.benchmarker.report_results(framework=self, test="query", results=results['results'])
         print "Complete"
     except AttributeError:
       pass
@@ -244,8 +241,7 @@ class FrameworkTest:
         remote_script = self.__generate_concurrency_script(self.fortune_url, self.port)
         self.__run_benchmark(remote_script, self.benchmarker.output_file(self.name, 'fortune'))
         results = self.__parse_test('fortune')
-        self.benchmarker.report_results(framework=self, test="fortune", requests=results['requests'], latency=results['latency'],
-          results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+        self.benchmarker.report_results(framework=self, test="fortune", results=results['results'])
         print "Complete"
     except AttributeError:
       pass
@@ -257,8 +253,7 @@ class FrameworkTest:
         remote_script = self.__generate_query_script(self.update_url, self.port)
         self.__run_benchmark(remote_script, self.benchmarker.output_file(self.name, 'update'))
         results = self.__parse_test('update')
-        self.benchmarker.report_results(framework=self, test="update", requests=results['requests'], latency=results['latency'],
-          results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+        self.benchmarker.report_results(framework=self, test="update", results=results['results'])
         print "Complete"
     except AttributeError:
       pass
@@ -274,32 +269,27 @@ class FrameworkTest:
     # JSON
     if os.path.exists(self.benchmarker.output_file(self.name, 'json')):
       results = self.__parse_test('json')
-      self.benchmarker.report_results(framework=self, test="json", requests=results['requests'], latency=results['latency'],
-        results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+      self.benchmarker.report_results(framework=self, test="json", results=results['results'])
     
     # DB
     if os.path.exists(self.benchmarker.output_file(self.name, 'db')):
       results = self.__parse_test('db')
-      self.benchmarker.report_results(framework=self, test="db", requests=results['requests'], latency=results['latency'],
-        results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+      self.benchmarker.report_results(framework=self, test="db", results=results['results'])
     
     # Query
     if os.path.exists(self.benchmarker.output_file(self.name, 'query')):
       results = self.__parse_test('query')
-      self.benchmarker.report_results(framework=self, test="query", requests=results['requests'], latency=results['latency'],
-        results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+      self.benchmarker.report_results(framework=self, test="query", results=results['results'])
 
     # Fortune
     if os.path.exists(self.benchmarker.output_file(self.name, 'fortune')):
       results = self.__parse_test('fortune')
-      self.benchmarker.report_results(framework=self, test="fortune", requests=results['requests'], latency=results['latency'],
-        results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+      self.benchmarker.report_results(framework=self, test="fortune", results=results['results'])
 
     # Update
     if os.path.exists(self.benchmarker.output_file(self.name, 'update')):
       results = self.__parse_test('update')
-      self.benchmarker.report_results(framework=self, test="update", requests=results['requests'], latency=results['latency'],
-        results=results['results'], total_time=results['total_time'], errors=results['errors'], total_requests=results['totalRequests'])
+      self.benchmarker.report_results(framework=self, test="update", results=results['results'])
   ############################################################
   # End parse_all
   ############################################################
@@ -311,94 +301,83 @@ class FrameworkTest:
     try:
       results = dict()
       results['results'] = []
-      results['total_time'] = 0
-      results['totalRequests'] = 0
-      results['latency'] = dict()
-      results['latency']['avg'] = 0
-      results['latency']['stdev'] = 0
-      results['latency']['max'] = 0
-      results['latency']['stdevPercent'] = 0
-      results['requests'] = dict()
-      results['requests']['avg'] = 0
-      results['requests']['stdev'] = 0
-      results['requests']['max'] = 0
-      results['requests']['stdevPercent'] = 0
-      results['errors'] = dict()
-      results['errors']['connect'] = 0
-      results['errors']['read'] = 0
-      results['errors']['write'] = 0
-      results['errors']['timeout'] = 0
-      results['errors']['5xx'] = 0
+      
       with open(self.benchmarker.output_file(self.name, test_type)) as raw_data:
-        is_warmup = False
+        is_warmup = True
+        rawData = None
         for line in raw_data:
 
           if "Queries:" in line or "Concurrency:" in line:
             is_warmup = False
+            rawData = None
             continue
           if "Warmup" in line or "Primer" in line:
             is_warmup = True
             continue
 
           if not is_warmup:
-            if "Requests/sec:" in line:
-              m = re.search("Requests/sec:\s+([0-9]+)", line)
-              results['results'].append(m.group(1))
+            if rawData == None:
+              rawData = dict()
+              results['results'].append(rawData)
+
+            #if "Requests/sec:" in line:
+            #  m = re.search("Requests/sec:\s+([0-9]+)", line)
+            #  rawData['reportedResults'] = m.group(1)
               
             # search for weighttp data such as succeeded and failed.
             if "Latency" in line:
               m = re.findall("([0-9]+\.*[0-9]*[us|ms|s|m|%]+)", line)
               if len(m) == 4:
-                results['latency']['avg'] = m[0]
-                results['latency']['stdev'] = m[1]
-                results['latency']['max'] = m[2]
-                results['latency']['stdevPercent'] = m[3]
+                rawData['latencyAvg'] = m[0]
+                rawData['latencyStdev'] = m[1]
+                rawData['latencyMax'] = m[2]
+            #    rawData['latencyStdevPercent'] = m[3]
             
-            if "Req/Sec" in line:
-              m = re.findall("([0-9]+\.*[0-9]*[k|%]*)", line)
-              if len(m) == 4:
-                results['requests']['avg'] = m[0]
-                results['requests']['stdev'] = m[1]
-                results['requests']['max'] = m[2]
-                results['requests']['stdevPercent'] = m[3]
+            #if "Req/Sec" in line:
+            #  m = re.findall("([0-9]+\.*[0-9]*[k|%]*)", line)
+            #  if len(m) == 4:
+            #    rawData['requestsAvg'] = m[0]
+            #    rawData['requestsStdev'] = m[1]
+            #    rawData['requestsMax'] = m[2]
+            #    rawData['requestsStdevPercent'] = m[3]
               
-            if "requests in" in line:
-              m = re.search("requests in ([0-9]+\.*[0-9]*[ms|s|m|h]+)", line)
-              if m != None: 
-                # parse out the raw time, which may be in minutes or seconds
-                raw_time = m.group(1)
-                if "ms" in raw_time:
-                  results['total_time'] += float(raw_time[:len(raw_time)-2]) / 1000.0
-                elif "s" in raw_time:
-                  results['total_time'] += float(raw_time[:len(raw_time)-1])
-                elif "m" in raw_time:
-                  results['total_time'] += float(raw_time[:len(raw_time)-1]) * 60.0
-                elif "h" in raw_time:
-                  results['total_time'] += float(raw_time[:len(raw_time)-1]) * 3600.0
+            #if "requests in" in line:
+            #  m = re.search("requests in ([0-9]+\.*[0-9]*[ms|s|m|h]+)", line)
+            #  if m != None: 
+            #    # parse out the raw time, which may be in minutes or seconds
+            #    raw_time = m.group(1)
+            #    if "ms" in raw_time:
+            #      rawData['total_time'] = float(raw_time[:len(raw_time)-2]) / 1000.0
+            #    elif "s" in raw_time:
+            #      rawData['total_time'] = float(raw_time[:len(raw_time)-1])
+            #    elif "m" in raw_time:
+            #      rawData['total_time'] = float(raw_time[:len(raw_time)-1]) * 60.0
+            #    elif "h" in raw_time:
+            #      rawData['total_time'] = float(raw_time[:len(raw_time)-1]) * 3600.0
            
             if "requests in" in line:
               m = re.search("([0-9]+) requests in", line)
               if m != None: 
-                results['totalRequests'] += int(m.group(1))
+                rawData['totalRequests'] = int(m.group(1))
             
             if "Socket errors" in line:
               if "connect" in line:
                 m = re.search("connect ([0-9]+)", line)
-                results['errors']['connect'] += int(m.group(1))
+                rawData['connect'] = int(m.group(1))
               if "read" in line:
                 m = re.search("read ([0-9]+)", line)
-                results['errors']['read'] += int(m.group(1))
+                rawData['read'] = int(m.group(1))
               if "write" in line:
                 m = re.search("write ([0-9]+)", line)
-                results['errors']['write'] += int(m.group(1))
+                rawData['write'] = int(m.group(1))
               if "timeout" in line:
                 m = re.search("timeout ([0-9]+)", line)
-                results['errors']['timeout'] += int(m.group(1))
+                rawData['timeout'] = int(m.group(1))
             
             if "Non-2xx" in line:
               m = re.search("Non-2xx or 3xx responses: ([0-9]+)", line)
               if m != None: 
-                results['errors']['5xx'] += int(m.group(1))
+                rawData['5xx'] = int(m.group(1))
               
 
       return results