feed graphite pickle fomat

feed_pickle.py

import argparse
import socket
import time
import pickle
import struct


CARBON_SERVER = '0.0.0.0'
CARBON_PORT = 2004


parser = argparse.ArgumentParser()
parser.add_argument('metric_path')
parser.add_argument('value')
args = parser.parse_args()

def get_message(path,value,ts):
    listOfMetricTuples = [ (path,(ts,value)),]
    payload = pickle.dumps(listOfMetricTuples)
    header = struct.pack("!L", len(payload))
    message = header + payload
    return message


if __name__ == '__main__':
    timestamp = int(time.time())
    message = '%s %s %d\n' % (args.metric_path, args.value, timestamp)
    bin_message = get_message(args.metric_path,args.value,timestamp)

    print 'sending message:\n%s' % message
    sock = socket.socket()
    sock.connect((CARBON_SERVER, CARBON_PORT))
    sock.sendall(bin_message)
    sock.close()