statsdproxy 0.4.1

A proxy for transforming, pre-aggregating and routing statsd metrics
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

import socket
import sys

try:
    PORT = int(sys.argv[1])
except IndexError:
    PORT = int(input("port: "))

SOCK = socket.socket(type=socket.SOCK_DGRAM)
SOCK.bind(("127.0.0.1", PORT))
DATA = b"users.online:1|c|@0.5|#country:china"
DATA = b"\n".join([DATA] * 221)
while True:
    d = SOCK.recv(8192)
    if d != DATA:
        print("mismatch:", d, file=sys.stderr)
        print("mismatch:", len(d), file=sys.stderr)
        break
    sys.stdout.buffer.write(d)
    sys.stdout.flush()