framework_test.py 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881
  1. from benchmark.fortune_html_parser import FortuneHTMLParser
  2. from setup.linux import setup_util
  3. from benchmark.test_types import *
  4. import importlib
  5. import os
  6. import subprocess
  7. import time
  8. import re
  9. from pprint import pprint
  10. import sys
  11. import traceback
  12. import json
  13. import logging
  14. import csv
  15. import shlex
  16. import math
  17. from collections import OrderedDict
  18. from threading import Thread
  19. from threading import Event
  20. from utils import header
  21. from datetime import datetime
  22. from datetime import timedelta
  23. class FrameworkTest:
  24. headers_template = "-H 'Host: localhost' -H '{accept}' -H 'Connection: keep-alive'"
  25. # Used for test types that require no pipelining or query string params.
  26. concurrency_template = """
  27. echo ""
  28. echo "---------------------------------------------------------"
  29. echo " Running Primer {name}"
  30. echo " {wrk} {headers} -d 5 -c 8 --timeout 8 -t 8 \"http://{server_host}:{port}{url}\""
  31. echo "---------------------------------------------------------"
  32. echo ""
  33. {wrk} {headers} -d 5 -c 8 --timeout 8 -t 8 "http://{server_host}:{port}{url}"
  34. sleep 5
  35. echo ""
  36. echo "---------------------------------------------------------"
  37. echo " Running Warmup {name}"
  38. echo " {wrk} {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} \"http://{server_host}:{port}{url}\""
  39. echo "---------------------------------------------------------"
  40. echo ""
  41. {wrk} {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} "http://{server_host}:{port}{url}"
  42. sleep 5
  43. echo ""
  44. echo "---------------------------------------------------------"
  45. echo " Synchronizing time"
  46. echo "---------------------------------------------------------"
  47. echo ""
  48. ntpdate -s pool.ntp.org
  49. for c in {levels}
  50. do
  51. echo ""
  52. echo "---------------------------------------------------------"
  53. echo " Concurrency: $c for {name}"
  54. echo " {wrk} {headers} -d {duration} -c $c --timeout $c -t $(($c>{max_threads}?{max_threads}:$c)) \"http://{server_host}:{port}{url}\""
  55. echo "---------------------------------------------------------"
  56. echo ""
  57. STARTTIME=$(date +"%s")
  58. {wrk} {headers} -d {duration} -c $c --timeout $c -t "$(($c>{max_threads}?{max_threads}:$c))" http://{server_host}:{port}{url}
  59. echo "STARTTIME $STARTTIME"
  60. echo "ENDTIME $(date +"%s")"
  61. sleep 2
  62. done
  63. """
  64. # Used for test types that require pipelining.
  65. pipeline_template = """
  66. echo ""
  67. echo "---------------------------------------------------------"
  68. echo " Running Primer {name}"
  69. echo " {wrk} {headers} -d 5 -c 8 --timeout 8 -t 8 \"http://{server_host}:{port}{url}\""
  70. echo "---------------------------------------------------------"
  71. echo ""
  72. {wrk} {headers} -d 5 -c 8 --timeout 8 -t 8 "http://{server_host}:{port}{url}"
  73. sleep 5
  74. echo ""
  75. echo "---------------------------------------------------------"
  76. echo " Running Warmup {name}"
  77. echo " {wrk} {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} \"http://{server_host}:{port}{url}\""
  78. echo "---------------------------------------------------------"
  79. echo ""
  80. {wrk} {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} "http://{server_host}:{port}{url}"
  81. sleep 5
  82. echo ""
  83. echo "---------------------------------------------------------"
  84. echo " Synchronizing time"
  85. echo "---------------------------------------------------------"
  86. echo ""
  87. ntpdate -s pool.ntp.org
  88. for c in {levels}
  89. do
  90. echo ""
  91. echo "---------------------------------------------------------"
  92. echo " Concurrency: $c for {name}"
  93. echo " {wrk} {headers} -d {duration} -c $c --timeout $c -t $(($c>{max_threads}?{max_threads}:$c)) \"http://{server_host}:{port}{url}\" -s ~/pipeline.lua -- {pipeline}"
  94. echo "---------------------------------------------------------"
  95. echo ""
  96. STARTTIME=$(date +"%s")
  97. {wrk} {headers} -d {duration} -c $c --timeout $c -t "$(($c>{max_threads}?{max_threads}:$c))" http://{server_host}:{port}{url} -s ~/pipeline.lua -- {pipeline}
  98. echo "STARTTIME $STARTTIME"
  99. echo "ENDTIME $(date +"%s")"
  100. sleep 2
  101. done
  102. """
  103. # Used for test types that require a database -
  104. # These tests run at a static concurrency level and vary the size of
  105. # the query sent with each request
  106. query_template = """
  107. echo ""
  108. echo "---------------------------------------------------------"
  109. echo " Running Primer {name}"
  110. echo " wrk {headers} -d 5 -c 8 --timeout 8 -t 8 \"http://{server_host}:{port}{url}2\""
  111. echo "---------------------------------------------------------"
  112. echo ""
  113. wrk {headers} -d 5 -c 8 --timeout 8 -t 8 "http://{server_host}:{port}{url}2"
  114. sleep 5
  115. echo ""
  116. echo "---------------------------------------------------------"
  117. echo " Running Warmup {name}"
  118. echo " wrk {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} \"http://{server_host}:{port}{url}2\""
  119. echo "---------------------------------------------------------"
  120. echo ""
  121. wrk {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} "http://{server_host}:{port}{url}2"
  122. sleep 5
  123. echo ""
  124. echo "---------------------------------------------------------"
  125. echo " Synchronizing time"
  126. echo "---------------------------------------------------------"
  127. echo ""
  128. ntpdate -s pool.ntp.org
  129. for c in {levels}
  130. do
  131. echo ""
  132. echo "---------------------------------------------------------"
  133. echo " Queries: $c for {name}"
  134. echo " wrk {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} \"http://{server_host}:{port}{url}$c\""
  135. echo "---------------------------------------------------------"
  136. echo ""
  137. STARTTIME=$(date +"%s")
  138. wrk {headers} -d {duration} -c {max_concurrency} --timeout {max_concurrency} -t {max_threads} "http://{server_host}:{port}{url}$c"
  139. echo "STARTTIME $STARTTIME"
  140. echo "ENDTIME $(date +"%s")"
  141. sleep 2
  142. done
  143. """
  144. ############################################################
  145. # start(benchmarker)
  146. # Start the test using it's setup file
  147. ############################################################
  148. def start(self, out, err):
  149. # Setup environment variables
  150. setup_util.replace_environ(config='$FWROOT/config/benchmark_profile',
  151. command='''\
  152. export TROOT=%s && \
  153. export IROOT=%s && \
  154. export DBHOST=%s && \
  155. export MAX_THREADS=%s \
  156. ''' % (
  157. self.directory,
  158. self.install_root,
  159. self.database_host,
  160. self.benchmarker.threads))
  161. # Run the module start inside parent of TROOT
  162. # - we use the parent as a historical accident, a number of tests
  163. # refer to their TROOT maually still
  164. previousDir = os.getcwd()
  165. os.chdir(os.path.dirname(self.troot))
  166. logging.info("Running setup module start (cwd=%s)", self.directory)
  167. # Run the start script for the test as the "testrunner" user
  168. #
  169. # `sudo` - Switching user requires superuser privs
  170. # -u [username] The username
  171. # -E Preserves the current environment variables
  172. # -H Forces the home var (~) to be reset to the user specified
  173. # `stdbuf` - Disable buffering, send output to python ASAP
  174. # -o0 zero-sized buffer for stdout
  175. # -e0 zero-sized buffer for stderr
  176. # `bash` - Run the setup.sh script using bash
  177. # -e Force bash to exit on first error
  178. # -x Turn on bash tracing e.g. print commands before running
  179. #
  180. # Most servers do not output to stdout/stderr while serving
  181. # requests so there is no performance hit from disabling
  182. # output buffering. This disabling is necessary to
  183. # a) allow TFB to show output in real time and b) avoid loosing
  184. # output in the buffer when the testrunner processes are forcibly
  185. # killed
  186. #
  187. # See http://www.pixelbeat.org/programming/stdio_buffering/
  188. # See https://blogs.gnome.org/markmc/2013/06/04/async-io-and-python/
  189. # See http://eyalarubas.com/python-subproc-nonblock.html
  190. command = 'sudo -u %s -E -H stdbuf -o0 -e0 bash -ex %s.sh' % (self.benchmarker.runner_user, self.setup_file)
  191. debug_command = '''\
  192. export FWROOT=%s && \\
  193. export TROOT=%s && \\
  194. export IROOT=%s && \\
  195. export DBHOST=%s && \\
  196. export MAX_THREADS=%s && \\
  197. cd %s && \\
  198. %s''' % (self.fwroot,
  199. self.directory,
  200. self.install_root,
  201. self.database_host,
  202. self.benchmarker.threads,
  203. self.directory,
  204. command)
  205. logging.info("To run %s manually, copy/paste this:\n%s", self.name, debug_command)
  206. def tee_output(prefix, line):
  207. # Needs to be one atomic write
  208. # Explicitly use UTF-8 as it's the most common framework output
  209. # TODO improve encoding handling
  210. line = prefix.encode('utf-8') + line
  211. # Log to current terminal
  212. sys.stdout.write(line)
  213. sys.stdout.flush()
  214. # logging.error("".join([prefix, line]))
  215. out.write(line)
  216. out.flush()
  217. # Start the setup.sh command
  218. p = subprocess.Popen(command, cwd=self.directory,
  219. shell=True, stdout=subprocess.PIPE,
  220. stderr=subprocess.STDOUT)
  221. nbsr = setup_util.NonBlockingStreamReader(p.stdout,
  222. "%s: %s.sh and framework processes have terminated" % (self.name, self.setup_file))
  223. # Setup a timeout
  224. timeout = datetime.now() + timedelta(minutes = 20)
  225. time_remaining = timeout - datetime.now()
  226. # Flush output until setup.sh work is finished. This is
  227. # either a) when setup.sh exits b) when the port is bound
  228. # c) when we run out of time. Note that 'finished' doesn't
  229. # guarantee setup.sh process is dead - the OS may choose to make
  230. # setup.sh a zombie process if it still has living children
  231. #
  232. # Note: child processes forked (using &) will remain alive
  233. # after setup.sh has exited. The will have inherited the
  234. # stdout/stderr descriptors and will be directing their
  235. # output to the pipes.
  236. #
  237. prefix = "Setup %s: " % self.name
  238. while not (p.poll()
  239. or self.benchmarker.is_port_bound(self.port)
  240. or time_remaining.total_seconds() < 0):
  241. # The conditions above are slow to check, so
  242. # we will delay output substantially if we only
  243. # print one line per condition check.
  244. # Adding a tight loop here mitigates the effect,
  245. # ensuring that most of the output directly from
  246. # setup.sh is sent to tee_output before the outer
  247. # loop exits and prints things like "setup.sh exited"
  248. #
  249. for i in xrange(10):
  250. try:
  251. line = nbsr.readline(0.05)
  252. if line:
  253. tee_output(prefix, line)
  254. except setup_util.EndOfStream:
  255. tee_output(prefix, "Setup has terminated\n")
  256. break
  257. time_remaining = timeout - datetime.now()
  258. # Did we time out?
  259. if time_remaining.total_seconds() < 0:
  260. tee_output(prefix, "%s.sh timed out!! Aborting...\n" % self.setup_file)
  261. p.kill()
  262. return 1
  263. # What's our return code?
  264. # If setup.sh has terminated, use that code
  265. # Otherwise, detect if the port was bound
  266. retcode = (p.poll() or 0 if self.benchmarker.is_port_bound(self.port) else 1)
  267. if p.poll():
  268. tee_output(prefix, "%s.sh process exited with %s\n" % (self.setup_file, p.poll()))
  269. elif self.benchmarker.is_port_bound(self.port):
  270. tee_output(prefix, "%s.sh exited due to bound port\n" % self.setup_file)
  271. # Before we return control to the benchmarker, spin up a
  272. # thread to keep an eye on the pipes in case the running
  273. # framework uses stdout/stderr. Once all processes accessing
  274. # the subprocess.PIPEs are dead, this thread will terminate.
  275. # Use a different prefix to indicate this is the framework
  276. # speaking
  277. prefix = "Server %s: " % self.name
  278. def watch_child_pipes(nbsr, prefix):
  279. while True:
  280. try:
  281. line = nbsr.readline(60)
  282. if line:
  283. tee_output(prefix, line)
  284. except setup_util.EndOfStream:
  285. tee_output(prefix, "Framework processes have terminated\n")
  286. return
  287. watch_thread = Thread(target = watch_child_pipes,
  288. args = (nbsr, prefix))
  289. watch_thread.daemon = True
  290. watch_thread.start()
  291. logging.info("Executed %s.sh, returning %s", self.setup_file, retcode)
  292. os.chdir(previousDir)
  293. return retcode
  294. ############################################################
  295. # End start
  296. ############################################################
  297. ############################################################
  298. # verify_urls
  299. # Verifys each of the URLs for this test. THis will sinply
  300. # curl the URL and check for it's return status.
  301. # For each url, a flag will be set on this object for whether
  302. # or not it passed
  303. # Returns True if all verifications succeeded
  304. ############################################################
  305. def verify_urls(self, out, err):
  306. result = True
  307. def verify_type(test_type):
  308. test = self.runTests[test_type]
  309. test.setup_out_err(out, err)
  310. out.write(header("VERIFYING %s" % test_type.upper()))
  311. base_url = "http://%s:%s" % (self.benchmarker.server_host, self.port)
  312. try:
  313. results = test.verify(base_url)
  314. except Exception as e:
  315. results = [('fail',"""Caused Exception in TFB
  316. This almost certainly means your return value is incorrect,
  317. but also that you have found a bug. Please submit an issue
  318. including this message: %s\n%s""" % (e, traceback.format_exc()),
  319. base_url)]
  320. logging.warning("Verifying test %s for %s caused an exception: %s", test_type, self.name, e)
  321. traceback.format_exc()
  322. test.failed = any(result is 'fail' for (result, reason, url) in results)
  323. test.warned = any(result is 'warn' for (result, reason, url) in results)
  324. test.passed = all(result is 'pass' for (result, reason, url) in results)
  325. def output_result(result, reason, url):
  326. out.write(" %s for %s\n" % (result.upper(), url))
  327. print " %s for %s" % (result.upper(), url)
  328. if reason is not None and len(reason) != 0:
  329. for line in reason.splitlines():
  330. out.write(" " + line + '\n')
  331. print " " + line
  332. [output_result(r1,r2,url) for (r1, r2, url) in results]
  333. if test.failed:
  334. self.benchmarker.report_verify_results(self, test_type, 'fail')
  335. elif test.warned:
  336. self.benchmarker.report_verify_results(self, test_type, 'warn')
  337. elif test.passed:
  338. self.benchmarker.report_verify_results(self, test_type, 'pass')
  339. else:
  340. raise Exception("Unknown error - test did not pass,warn,or fail")
  341. result = True
  342. for test_type in self.runTests:
  343. verify_type(test_type)
  344. if self.runTests[test_type].failed:
  345. result = False
  346. return result
  347. ############################################################
  348. # End verify_urls
  349. ############################################################
  350. ############################################################
  351. # benchmark
  352. # Runs the benchmark for each type of test that it implements
  353. # JSON/DB/Query.
  354. ############################################################
  355. def benchmark(self, out, err):
  356. def benchmark_type(test_type):
  357. out.write("BENCHMARKING %s ... " % test_type.upper())
  358. test = self.runTests[test_type]
  359. test.setup_out_err(out, err)
  360. output_file = self.benchmarker.output_file(self.name, test_type)
  361. if not os.path.exists(output_file):
  362. # Open to create the empty file
  363. with open(output_file, 'w'):
  364. pass
  365. if not test.failed:
  366. if test_type == 'plaintext': # One special case
  367. remote_script = self.__generate_pipeline_script(test.get_url(), self.port, test.accept_header)
  368. elif test_type == 'query' or test_type == 'update':
  369. remote_script = self.__generate_query_script(test.get_url(), self.port, test.accept_header)
  370. else:
  371. remote_script = self.__generate_concurrency_script(test.get_url(), self.port, test.accept_header)
  372. # Begin resource usage metrics collection
  373. self.__begin_logging(test_type)
  374. # Run the benchmark
  375. with open(output_file, 'w') as raw_file:
  376. p = subprocess.Popen(self.benchmarker.client_ssh_string.split(" "), stdin=subprocess.PIPE, stdout=raw_file, stderr=err)
  377. p.communicate(remote_script)
  378. err.flush()
  379. # End resource usage metrics collection
  380. self.__end_logging()
  381. results = self.__parse_test(test_type)
  382. print "Benchmark results:"
  383. pprint(results)
  384. self.benchmarker.report_benchmark_results(framework=self, test=test_type, results=results['results'])
  385. out.write( "Complete\n" )
  386. out.flush()
  387. for test_type in self.runTests:
  388. benchmark_type(test_type)
  389. ############################################################
  390. # End benchmark
  391. ############################################################
  392. ############################################################
  393. # parse_all
  394. # Method meant to be run for a given timestamp
  395. ############################################################
  396. def parse_all(self):
  397. for test_type in self.runTests:
  398. if os.path.exists(self.benchmarker.get_output_file(self.name, test_type)):
  399. results = self.__parse_test(test_type)
  400. self.benchmarker.report_benchmark_results(framework=self, test=test_type, results=results['results'])
  401. ############################################################
  402. # __parse_test(test_type)
  403. ############################################################
  404. def __parse_test(self, test_type):
  405. try:
  406. results = dict()
  407. results['results'] = []
  408. stats = []
  409. if os.path.exists(self.benchmarker.get_output_file(self.name, test_type)):
  410. with open(self.benchmarker.output_file(self.name, test_type)) as raw_data:
  411. is_warmup = True
  412. rawData = None
  413. for line in raw_data:
  414. if "Queries:" in line or "Concurrency:" in line:
  415. is_warmup = False
  416. rawData = None
  417. continue
  418. if "Warmup" in line or "Primer" in line:
  419. is_warmup = True
  420. continue
  421. if not is_warmup:
  422. if rawData == None:
  423. rawData = dict()
  424. results['results'].append(rawData)
  425. #if "Requests/sec:" in line:
  426. # m = re.search("Requests/sec:\s+([0-9]+)", line)
  427. # rawData['reportedResults'] = m.group(1)
  428. # search for weighttp data such as succeeded and failed.
  429. if "Latency" in line:
  430. m = re.findall("([0-9]+\.*[0-9]*[us|ms|s|m|%]+)", line)
  431. if len(m) == 4:
  432. rawData['latencyAvg'] = m[0]
  433. rawData['latencyStdev'] = m[1]
  434. rawData['latencyMax'] = m[2]
  435. # rawData['latencyStdevPercent'] = m[3]
  436. #if "Req/Sec" in line:
  437. # m = re.findall("([0-9]+\.*[0-9]*[k|%]*)", line)
  438. # if len(m) == 4:
  439. # rawData['requestsAvg'] = m[0]
  440. # rawData['requestsStdev'] = m[1]
  441. # rawData['requestsMax'] = m[2]
  442. # rawData['requestsStdevPercent'] = m[3]
  443. #if "requests in" in line:
  444. # m = re.search("requests in ([0-9]+\.*[0-9]*[ms|s|m|h]+)", line)
  445. # if m != None:
  446. # # parse out the raw time, which may be in minutes or seconds
  447. # raw_time = m.group(1)
  448. # if "ms" in raw_time:
  449. # rawData['total_time'] = float(raw_time[:len(raw_time)-2]) / 1000.0
  450. # elif "s" in raw_time:
  451. # rawData['total_time'] = float(raw_time[:len(raw_time)-1])
  452. # elif "m" in raw_time:
  453. # rawData['total_time'] = float(raw_time[:len(raw_time)-1]) * 60.0
  454. # elif "h" in raw_time:
  455. # rawData['total_time'] = float(raw_time[:len(raw_time)-1]) * 3600.0
  456. if "requests in" in line:
  457. m = re.search("([0-9]+) requests in", line)
  458. if m != None:
  459. rawData['totalRequests'] = int(m.group(1))
  460. if "Socket errors" in line:
  461. if "connect" in line:
  462. m = re.search("connect ([0-9]+)", line)
  463. rawData['connect'] = int(m.group(1))
  464. if "read" in line:
  465. m = re.search("read ([0-9]+)", line)
  466. rawData['read'] = int(m.group(1))
  467. if "write" in line:
  468. m = re.search("write ([0-9]+)", line)
  469. rawData['write'] = int(m.group(1))
  470. if "timeout" in line:
  471. m = re.search("timeout ([0-9]+)", line)
  472. rawData['timeout'] = int(m.group(1))
  473. if "Non-2xx" in line:
  474. m = re.search("Non-2xx or 3xx responses: ([0-9]+)", line)
  475. if m != None:
  476. rawData['5xx'] = int(m.group(1))
  477. if "STARTTIME" in line:
  478. m = re.search("[0-9]+", line)
  479. rawData["startTime"] = int(m.group(0))
  480. if "ENDTIME" in line:
  481. m = re.search("[0-9]+", line)
  482. rawData["endTime"] = int(m.group(0))
  483. test_stats = self.__parse_stats(test_type, rawData["startTime"], rawData["endTime"], 1)
  484. # rawData["averageStats"] = self.__calculate_average_stats(test_stats)
  485. stats.append(test_stats)
  486. with open(self.benchmarker.stats_file(self.name, test_type) + ".json", "w") as stats_file:
  487. json.dump(stats, stats_file, indent=2)
  488. return results
  489. except IOError:
  490. return None
  491. ############################################################
  492. # End benchmark
  493. ############################################################
  494. ##########################################################################################
  495. # Private Methods
  496. ##########################################################################################
  497. ############################################################
  498. # __generate_concurrency_script(url, port)
  499. # Generates the string containing the bash script that will
  500. # be run on the client to benchmark a single test. This
  501. # specifically works for the variable concurrency tests (JSON
  502. # and DB)
  503. ############################################################
  504. def __generate_concurrency_script(self, url, port, accept_header, wrk_command="wrk"):
  505. headers = self.headers_template.format(accept=accept_header)
  506. return self.concurrency_template.format(max_concurrency=max(self.benchmarker.concurrency_levels),
  507. max_threads=self.benchmarker.threads, name=self.name, duration=self.benchmarker.duration,
  508. levels=" ".join("{}".format(item) for item in self.benchmarker.concurrency_levels),
  509. server_host=self.benchmarker.server_host, port=port, url=url, headers=headers, wrk=wrk_command)
  510. ############################################################
  511. # __generate_pipeline_script(url, port)
  512. # Generates the string containing the bash script that will
  513. # be run on the client to benchmark a single pipeline test.
  514. ############################################################
  515. def __generate_pipeline_script(self, url, port, accept_header, wrk_command="wrk"):
  516. headers = self.headers_template.format(accept=accept_header)
  517. return self.pipeline_template.format(max_concurrency=16384,
  518. max_threads=self.benchmarker.threads, name=self.name, duration=self.benchmarker.duration,
  519. levels=" ".join("{}".format(item) for item in [256,1024,4096,16384]),
  520. server_host=self.benchmarker.server_host, port=port, url=url, headers=headers, wrk=wrk_command,
  521. pipeline=16)
  522. ############################################################
  523. # __generate_query_script(url, port)
  524. # Generates the string containing the bash script that will
  525. # be run on the client to benchmark a single test. This
  526. # specifically works for the variable query tests (Query)
  527. ############################################################
  528. def __generate_query_script(self, url, port, accept_header):
  529. headers = self.headers_template.format(accept=accept_header)
  530. return self.query_template.format(max_concurrency=max(self.benchmarker.concurrency_levels),
  531. max_threads=self.benchmarker.threads, name=self.name, duration=self.benchmarker.duration,
  532. levels=" ".join("{}".format(item) for item in self.benchmarker.query_levels),
  533. server_host=self.benchmarker.server_host, port=port, url=url, headers=headers)
  534. ############################################################
  535. # Returns True if any test type this this framework test will use a DB
  536. ############################################################
  537. def requires_database(self):
  538. '''Returns True/False if this test requires a database'''
  539. return any(tobj.requires_db for (ttype,tobj) in self.runTests.iteritems())
  540. ############################################################
  541. # __begin_logging
  542. # Starts a thread to monitor the resource usage, to be synced with the client's time
  543. # TODO: MySQL and InnoDB are possible. Figure out how to implement them.
  544. ############################################################
  545. def __begin_logging(self, test_type):
  546. output_file = "{file_name}".format(file_name=self.benchmarker.get_stats_file(self.name, test_type))
  547. dstat_string = "dstat -afilmprsT --aio --fs --ipc --lock --raw --socket --tcp \
  548. --raw --socket --tcp --udp --unix --vm --disk-util \
  549. --rpc --rpcd --output {output_file}".format(output_file=output_file)
  550. cmd = shlex.split(dstat_string)
  551. dev_null = open(os.devnull, "w")
  552. self.subprocess_handle = subprocess.Popen(cmd, stdout=dev_null)
  553. ##############################################################
  554. # Begin __end_logging
  555. # Stops the logger thread and blocks until shutdown is complete.
  556. ##############################################################
  557. def __end_logging(self):
  558. self.subprocess_handle.terminate()
  559. self.subprocess_handle.communicate()
  560. ##############################################################
  561. # Begin __parse_stats
  562. # For each test type, process all the statistics, and return a multi-layered dictionary
  563. # that has a structure as follows:
  564. # (timestamp)
  565. # | (main header) - group that the stat is in
  566. # | | (sub header) - title of the stat
  567. # | | | (stat) - the stat itself, usually a floating point number
  568. ##############################################################
  569. def __parse_stats(self, test_type, start_time, end_time, interval):
  570. stats_dict = dict()
  571. stats_file = self.benchmarker.stats_file(self.name, test_type)
  572. with open(stats_file) as stats:
  573. while(stats.next() != "\n"): # dstat doesn't output a completely compliant CSV file - we need to strip the header
  574. pass
  575. stats_reader = csv.reader(stats)
  576. main_header = stats_reader.next()
  577. sub_header = stats_reader.next()
  578. time_row = sub_header.index("epoch")
  579. int_counter = 0
  580. for row in stats_reader:
  581. time = float(row[time_row])
  582. int_counter+=1
  583. if time < start_time:
  584. continue
  585. elif time > end_time:
  586. return stats_dict
  587. if int_counter % interval != 0:
  588. continue
  589. row_dict = dict()
  590. for nextheader in main_header:
  591. if nextheader != "":
  592. row_dict[nextheader] = dict()
  593. header = ""
  594. for item_num, column in enumerate(row):
  595. if(len(main_header[item_num]) != 0):
  596. header = main_header[item_num]
  597. row_dict[header][sub_header[item_num]] = float(column) # all the stats are numbers, so we want to make sure that they stay that way in json
  598. stats_dict[time] = row_dict
  599. return stats_dict
  600. ##############################################################
  601. # End __parse_stats
  602. ##############################################################
  603. def __getattr__(self, name):
  604. """For backwards compatibility, we used to pass benchmarker
  605. as the argument to the setup.sh files"""
  606. try:
  607. x = getattr(self.benchmarker, name)
  608. except AttributeError:
  609. print "AttributeError: %s not a member of FrameworkTest or Benchmarker" % name
  610. print "This is probably a bug"
  611. raise
  612. return x
  613. ##############################################################
  614. # Begin __calculate_average_stats
  615. # We have a large amount of raw data for the statistics that
  616. # may be useful for the stats nerds, but most people care about
  617. # a couple of numbers. For now, we're only going to supply:
  618. # * Average CPU
  619. # * Average Memory
  620. # * Total network use
  621. # * Total disk use
  622. # More may be added in the future. If they are, please update
  623. # the above list.
  624. # Note: raw_stats is directly from the __parse_stats method.
  625. # Recall that this consists of a dictionary of timestamps,
  626. # each of which contain a dictionary of stat categories which
  627. # contain a dictionary of stats
  628. ##############################################################
  629. def __calculate_average_stats(self, raw_stats):
  630. raw_stat_collection = dict()
  631. for timestamp, time_dict in raw_stats.items():
  632. for main_header, sub_headers in time_dict.items():
  633. item_to_append = None
  634. if 'cpu' in main_header:
  635. # We want to take the idl stat and subtract it from 100
  636. # to get the time that the CPU is NOT idle.
  637. item_to_append = sub_headers['idl'] - 100.0
  638. elif main_header == 'memory usage':
  639. item_to_append = sub_headers['used']
  640. elif 'net' in main_header:
  641. # Network stats have two parts - recieve and send. We'll use a tuple of
  642. # style (recieve, send)
  643. item_to_append = (sub_headers['recv'], sub_headers['send'])
  644. elif 'dsk' or 'io' in main_header:
  645. # Similar for network, except our tuple looks like (read, write)
  646. item_to_append = (sub_headers['read'], sub_headers['writ'])
  647. if item_to_append is not None:
  648. if main_header not in raw_stat_collection:
  649. raw_stat_collection[main_header] = list()
  650. raw_stat_collection[main_header].append(item_to_append)
  651. # Simple function to determine human readable size
  652. # http://stackoverflow.com/questions/1094841/reusable-library-to-get-human-readable-version-of-file-size
  653. def sizeof_fmt(num):
  654. # We'll assume that any number we get is convertable to a float, just in case
  655. num = float(num)
  656. for x in ['bytes','KB','MB','GB']:
  657. if num < 1024.0 and num > -1024.0:
  658. return "%3.1f%s" % (num, x)
  659. num /= 1024.0
  660. return "%3.1f%s" % (num, 'TB')
  661. # Now we have our raw stats in a readable format - we need to format it for display
  662. # We need a floating point sum, so the built in sum doesn't cut it
  663. display_stat_collection = dict()
  664. for header, values in raw_stat_collection.items():
  665. display_stat = None
  666. if 'cpu' in header:
  667. display_stat = sizeof_fmt(math.fsum(values) / len(values))
  668. elif main_header == 'memory usage':
  669. display_stat = sizeof_fmt(math.fsum(values) / len(values))
  670. elif 'net' in main_header:
  671. receive, send = zip(*values) # unzip
  672. display_stat = {'receive': sizeof_fmt(math.fsum(receive)), 'send': sizeof_fmt(math.fsum(send))}
  673. else: # if 'dsk' or 'io' in header:
  674. read, write = zip(*values) # unzip
  675. display_stat = {'read': sizeof_fmt(math.fsum(read)), 'write': sizeof_fmt(math.fsum(write))}
  676. display_stat_collection[header] = display_stat
  677. return display_stat
  678. ###########################################################################################
  679. # End __calculate_average_stats
  680. #########################################################################################
  681. ##########################################################################################
  682. # Constructor
  683. ##########################################################################################
  684. def __init__(self, name, directory, benchmarker, runTests, args):
  685. self.name = name
  686. self.directory = directory
  687. self.benchmarker = benchmarker
  688. self.runTests = runTests
  689. self.fwroot = benchmarker.fwroot
  690. self.approach = ""
  691. self.classification = ""
  692. self.database = ""
  693. self.framework = ""
  694. self.language = ""
  695. self.orm = ""
  696. self.platform = ""
  697. self.webserver = ""
  698. self.os = ""
  699. self.database_os = ""
  700. self.display_name = ""
  701. self.notes = ""
  702. self.versus = ""
  703. # setup logging
  704. logging.basicConfig(stream=sys.stderr, level=logging.INFO)
  705. self.install_root="%s/%s" % (self.fwroot, "installs")
  706. if benchmarker.install_strategy is 'pertest':
  707. self.install_root="%s/pertest/%s" % (self.install_root, name)
  708. # Used in setup.sh scripts for consistency with
  709. # the bash environment variables
  710. self.troot = self.directory
  711. self.iroot = self.install_root
  712. self.__dict__.update(args)
  713. ############################################################
  714. # End __init__
  715. ############################################################
  716. ############################################################
  717. # End FrameworkTest
  718. ############################################################
  719. ##########################################################################################
  720. # Static methods
  721. ##########################################################################################
  722. ##############################################################
  723. # parse_config(config, directory, benchmarker)
  724. # parses a config file and returns a list of FrameworkTest
  725. # objects based on that config file.
  726. ##############################################################
  727. def parse_config(config, directory, benchmarker):
  728. tests = []
  729. # This sort ordering is set up specifically to return the length
  730. # of the test name. There were SO many problems involved with
  731. # 'plaintext' being run first (rather, just not last) that we
  732. # needed to ensure that it was run last for every framework.
  733. def testOrder(type_name):
  734. return len(type_name)
  735. # The config object can specify multiple tests
  736. # Loop over them and parse each into a FrameworkTest
  737. for test in config['tests']:
  738. names = [name for (name,keys) in test.iteritems()]
  739. if "default" not in names:
  740. logging.warn("Framework %s does not define a default test in benchmark_config.json", config['framework'])
  741. for test_name, test_keys in test.iteritems():
  742. # Prefix all test names with framework except 'default' test
  743. if test_name == 'default':
  744. test_name = config['framework']
  745. else:
  746. test_name = "%s-%s" % (config['framework'], test_name)
  747. # Ensure FrameworkTest.framework is available
  748. if not test_keys['framework']:
  749. test_keys['framework'] = config['framework']
  750. #if test_keys['framework'].lower() != config['framework'].lower():
  751. # print Exception("benchmark_config.json for test %s is invalid - test framework '%s' must match benchmark_config.json framework '%s'" %
  752. # (test_name, test_keys['framework'], config['framework']))
  753. # Confirm required keys are present
  754. # TODO have a TechEmpower person confirm this list - I don't know what the website requires....
  755. required = ['language','webserver','classification','database','approach','orm','framework','os','database_os']
  756. if not all (key in test_keys for key in required):
  757. raise Exception("benchmark_config.json for test %s is invalid - missing required keys" % test_name)
  758. # Map test type to a parsed FrameworkTestType object
  759. runTests = dict()
  760. for type_name, type_obj in benchmarker.types.iteritems():
  761. try:
  762. runTests[type_name] = type_obj.copy().parse(test_keys)
  763. except AttributeError as ae:
  764. # This is quite common - most tests don't support all types
  765. # Quitely log it and move on (debug logging is on in travis and this causes
  766. # ~1500 lines of debug, so I'm totally ignoring it for now
  767. # logging.debug("Missing arguments for test type %s for framework test %s", type_name, test_name)
  768. pass
  769. # We need to sort by test_type to run
  770. sortedTestKeys = sorted(runTests.keys(), key=testOrder)
  771. sortedRunTests = OrderedDict()
  772. for sortedTestKey in sortedTestKeys:
  773. sortedRunTests[sortedTestKey] = runTests[sortedTestKey]
  774. # By passing the entire set of keys, each FrameworkTest will have a member for each key
  775. tests.append(FrameworkTest(test_name, directory, benchmarker, sortedRunTests, test_keys))
  776. return tests
  777. ##############################################################
  778. # End parse_config
  779. ##############################################################