from threading import Event
import json
import errno
+import six
import time
from mgr_module import MgrModule
osd_sum = pg_sum['by_osd']
pool_sum = pg_sum['by_pool']
data = []
- for osd_id, stats in osd_sum.iteritems():
+ for osd_id, stats in six.iteritems(osd_sum):
metadata = self.get_metadata('osd', "%s" % osd_id)
for stat in stats:
point_1 = {
}
}
data.append(point_1)
- for pool_id, stats in pool_sum.iteritems():
+ for pool_id, stats in six.iteritems(pool_sum):
for stat in stats:
point_2 = {
"measurement": "ceph_pg_summary_pool",
now = datetime.utcnow().isoformat() + 'Z'
- for daemon, counters in self.get_all_perf_counters().iteritems():
+ for daemon, counters in six.iteritems(self.get_all_perf_counters()):
svc_type, svc_id = daemon.split(".", 1)
metadata = self.get_metadata(svc_type, svc_id)