Simple UDP server to capture statsd repeater-counter events.

udp-statsd-capture.py

import re
import socket

# Handles only counter events                                                                                
stats_capture = re.compile(r'^(.*):(\d+)\|c$')

s = socket.socket(socket.AF_INET,
                  socket.SOCK_DGRAM)
s.bind(('127.0.0.1', 8001))

while True:
    data, addr = s.recvfrom(1024)
    try:
        bucket, count = stats_capture.match(data).groups()
        print('Incrementing bucket {0} by {1}'.format(bucket, count))
    except AttributeError:
        pass