iostat.py

iostat.py

from statsd import statsd
import sys

device = sys.argv[1]

while True:
    a = sys.stdin.readline().strip()
    data = a.split()
    if len(data) == 3:
        try:
            values = [float(d) for d in data]
            statsd.gauge("system.io.tx_size", float(values[0]) * 1024, tags=[device])
            statsd.gauge("system.io.tx_per_s", float(values[1]), tags=[device])
            stastd.gauge("system.io.throughput", float(values[2]) * 1024 * 1024, tags=[device])
        except:
            pass

iostat -w 1 -d disk1 | python iostat.py disk0

Sorry, I meant:

iostat -w 1 -d disk1 | python iostat.py disk1