graphite_transf.py

gistfile1.txt

SLA = 5
FAILED = []

make_positive(ts):
    return [t, 1 for t, v in ts]:

for v in time_series:
    if v:
        if len(FAILED) <= SLA:
            send_to_graphite(make_positive(FAILED) + [v])
            FAILED = []
        else:
            send_to_graphite(FAILED + [v])
            FAILED = []
    else:
        if len(FAILED) > SLA:
            send_to_graphite([FAILED.pop(0)])
        FAILED.append(v)