python的kvm虚拟机状态值监控

857432

python获取kvm虚拟机状态值
测试代码，其中只包含了基本的信息，所有的信息都是通过libvirt的api来获取的。
import libvirt
import memcache
import os
import time
from xml.etree import ElementTree as ET

mc = memcache.Client(['192.168.0.112:11211'])
while True:
    conn = libvirt.open('qemu:///system')

    dom = conn.listDomainsID()
    for i in dom:
        vmm_id = conn.lookupByID(i)
        vmm_name = vmm_id.name()
        if "wrksp" in vmm_name:
            try:
        #    vmm_namevmm_name_id = vmm_name.split('-')[1]
                vmm_id_str = str(vmm_name)
                vmmid = vmm_id_str.split('-')[1]
                print vmmid
                vmm_dom_xml = vmm_id.XMLDesc(0)
                vmm_xml_name = vmm_id_str + '.' + 'xml'
                vmm_xml_path = '/tmp/' + vmm_xml_name
                print vmm_xml_path
                if os.path.exists(vmm_xml_path):
                    pass
                else :
                    os.mknod(vmm_xml_path)

                xml_open = open(vmm_xml_path,'w')
                for lines in vmm_dom_xml:
                    xml_open.write(lines)
                xml_open.close()

                vmm_xml_open = ET.parse(vmm_xml_path)
                path_list=[]
                path = vmm_xml_open.findall('//source')
                for i in path:
                    file1 = i.attrib
                    filename=file1.get('file')
                    if filename:
                        path_list.append(filename)

    #    print path_list
                interface_list = []
                interface = vmm_xml_open.findall('//target')
                for j in interface:
                    interface_network = j.attrib
                    dev1 = interface_network.get('dev')
                    dev3 = 'vnet'
                    dev2 = str(dev1)
                    if dev3 in dev2:
                        interface_list.append(dev1)

        #    print interface_list

                totalrd = vmmid + 'rd'
                totalrd_byte = 0
                totalwr = vmmid + 'wr'
                totalwr_byte = 0
                totalrx = vmmid + 'rx'
                totalrx_byte = 0
                totaltx = vmmid + 'tx'
                totaltx_byte = 0
                totalrp = vmmid + 'rp'
                totalrx_packet = 0
                totaltp = vmmid + 'tp'
                totaltx_packet = 0

                for image_file in  path_list:   
        #        print image_file
        #        size = vmm_id.blockInfo(image_file,0)
                    block_status = vmm_id.blockStatsFlags(image_file,0)

                    totalrd_bytetotalrd_byte = totalrd_byte + block_status['rd_bytes']
                    totalwr_bytetotalwr_byte = totalwr_byte + block_status['wr_bytes']
                print totalrd_byte   
                print totalwr_byte
        #        print totalwr_byte


                for interfaceinfo_path in interface_list:
                    interfaceinfo = vmm_id.interfaceStats(interfaceinfo_path)
                    totalrx_bytetotalrx_byte = totalrx_byte + interfaceinfo[0]
                    totalrx_packettotalrx_packet = totalrx_packet + interfaceinfo[1]
                    totaltx_bytetotaltx_byte = totaltx_byte + interfaceinfo[4]
                    totaltx_packettotaltx_packet = totaltx_packet + interfaceinfo[5]

                totalmem = vmmid + 'actual'
                totalmem_data = 0
                rssmem = vmmid + 'rss'
                rssmem_data = 0
                mem_status = vmm_id.memoryStats()
                totalmem_data = mem_status['actual']
                rssmem_data = mem_status['rss']   
        #    print totalmem_data
        #    print rssmem_data   

                totalcpu = vmmid + 'cpu'
                totalcpu_usage = 0
                cpu_time =  vmm_id.info()[4]
                timetime1 = time.time()
                time.sleep(3)
                timetime2 = time.time()
                cpu_new_time = vmm_id.info()[4]
                totalcpu_usage = int(((cpu_new_time - cpu_time)/((time2 - time1)*10000000))*100)
                print totalcpu_usage

                mc.set('centosliran', '1234', 20)
                mc.set('centos_clusterliran','345',20)
                mc.set_multi({totalrd:totalrd_byte,totalwr:totalwr_byte,totalrx:totalrx_byte,totaltx:totaltx_byte,totalrp:totalrx_packet,totaltp:totaltx_packet,totalmem:totalmem_data,rssmem:rssmem_data,totalcpu:totalcpu_usage},60)   
                    #value = mc.get('key')
                   # print value
            except:
                pass