statsd_perfomance_test.py

#!/usr/bin/env python

import multiprocessing
import bucky.statsd
import time
import timeit

try:
    import queue
except ImportError:
    import Queue as queue

queue = multiprocessing.Queue()

handler = bucky.statsd.StatsDHandler(queue, bucky.cfg)

def fill_and_compute_timers(handler):
  # Fill timers
  for x in range(100): # timer name
    for y in range(1000): # timer value, using random value is not good idea there
      handler.handle_timer("timer-%s" % (x), [y])

  # Compute metrics
  stime = int(time.time())
  handler.enqueue_timers(stime)

  # Clear queue
  while not queue.empty():
    queue.get()

# Warmup
fill_and_compute_timers(handler)

time = timeit.timeit('fill_and_compute_timers(handler)',
                     'from __main__ import fill_and_compute_timers, handler',
                     number=100)

print time

queue.close