agent/cloud_node_statistics.py

#!/usr/bin/env python
#  coding: utf-8

from SWSCloudNode import Node, StatisticsReporter
from SWSCloudNode import LXC
from SWSCloudNode import Qemu
from SWSCloudNode import QemuStats

cls_lxc = LXC()
cls_qemu = Qemu()
cls_node = Node()

for container in cls_lxc.list_containers():
    # print container
    info = cls_lxc.info(container)
    info['container_id'] = info['name']
    print (cls_node.report_container_stats(info['container_id'], info))
    # print info


"""
curl localhost:8089/node_stats/v1/compute/vms/04ea5600-89c6-11e6-b1e1-fb8145d56ed7 -X POST --header 'Content-Type: application/json'
"""

vms = cls_qemu.list().get('online')
for vm in vms:
    dom = vms.get(vm).get('hostname')
    data = dict(
        network=QemuStats().network(dom),
        cpu=QemuStats().cpu(dom),
        memory=QemuStats().memory(dom))
    print (StatisticsReporter().send_vm_statistics(dom, data))