statsd_exporter_test.py

from socket import socket, AF_INET, SOCK_DGRAM
import json

class StatsdClient(object):
    def __init__(self, host='localhost', port=8125):
        self.addr = (host, port)
        self.udp_sock = socket(AF_INET, SOCK_DGRAM)

    def gauge(self, name, value):
        metric = "{0}:{1}|{2}".format(name, value, "g")
        print "send " + metric
        self.udp_sock.sendto(metric, self.addr)

def main():
    c = StatsdClient(port=9125)
    metrics = [
        {"name": "metric_name1", "value": 1.1},
        {"name": "metric-name2", "value": 2.5},
        {"name": "metric.name3", "value": 3},
    ]

    for m in metrics:
        c.gauge(m["name"], m["value"])

main()