Send Data to Skyline

gistfile1.txt

def send_to_skyline(series, metric_set):

    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

    # Datapoints are {metric:[ [timestamp,value],[timestamp,value]...]}
    for record in series:
        metric = "%s.%s" % (metric_set, record['metric'])
        datapoint = [record['timestamp'],record['value']]
        packet = msgpack.packb((metric, datapoint))
        sock.sendto(packet, (socket.gethostname(), SKYLINE_UDP_PORT))

    return