Ceph Health in Python in a loop

ceph-health.py

#!/usr/bin/env python

import time
import rados
import json

def get_cluster_health(r):
    cmd = {"prefix":"status", "format":"json"}
    ret, buf, errs = r.mon_command(json.dumps(cmd), b'', timeout=5)
    result = json.loads(buf)
    return result['health']['status']

try:
    r = rados.Rados(conffile="/etc/ceph/ceph.conf")
    r.connect()

    for i in range(1000):
        print("{0}: {1}".format(time.time(), get_cluster_health(r)))
        time.sleep(1)
except KeyboardInterrupt:
    pass
finally:
    if r is not None:
        r.shutdown()