def run_periodic_checks(self):
ts = arrow.utcnow().timestamp
def deferreds():
return len(gc.get_referrers(Deferred))
def rss_mb():
rss = resource.getrusage(resource.RUSAGE_SELF).ru_maxrss/1024
if sys.platform.startswith('darwin'):
rss /= 1024
return rss
kpi_event = KpiEvent(
type=KpiEventType.slice,
ts=ts,
prefixes={
'voltha.internal.{}'.format(self.instance_id):
MetricValuePairs(metrics={
'deferreds': deferreds(),
'rss-mb': rss_mb(),
})
}
)
self.event_bus.publish('kpis', kpi_event)
log.debug('periodic-check', ts=ts)
评论列表
文章目录