技术

IT这个行当之需求与时间管理 golang结构体和包中的类型或基础类型定义方法 golang中结构体的初始化方法(new方法) 项目管理总结 python函数式编程之-装饰器(Decorators) python文件批量处理 Go,互联网时代的C Python推导式演变(Comprehensions) 项目管理感悟 golang学习简单例子 了解GitHub工作流【译】 PHP Socket的使用 Apache 日志文件格式及简单处理 Python脚本--下载合并SAE日志 PHP命名空间及自动加载 基于CSS3实现尖角面包屑 部署Ceilometer到已有环境中 OpenStack Ceilometer Collector代码解读 OpenStack Ceilometer数据存储与API源码解析 OpenStack Ceilometer中的Pipeline机制 OpenStack Ceilometer Compute Agent源码解读 学习Python动态扩展包stevedore 学习Python的ABC模块 Python包管理工具setuptools详解 OpenStack Horizon 中文本地化 WSGI学习 在虚拟机单机部署OpenStack Grizzly 学习使用python打包工具distutils python包工具之间的关系 给OpenStack创建Ubuntu镜像 OpenStack Grizzly Multihost部署文档 为什么使用pip而不是easy_install HTML中meta标签viewpoint的作用 交互式编程-IPython 页面提速之——数据缓存 给OpenStack创建Win7镜像 Ceilometer的命令行使用 部署一个ceilometer-horizon项目 给OpenStack创建Windows XP镜像 几种企业的存储系统 概念模型、逻辑模型、物理模型的区别 五中常见的开源协议整理(BSD,Apache,GPL,LGPL,MIT) OpenStack监控项目Ceilometer的一些术语 VNC和远程桌面的区别 OpenStack Ceilometer项目简介 虚拟化与云计算中KVM,Xen,Qemu的区别和联系 调试和修改OpenStack中的Horizon部分 JavaScript变量作用域 kanyun worker原理 kanyun server服务 在OpenStack中部署kanyun kanyun的api-client命令 sae下的python开发部署和一个简单例子 OpenStack Nova内部机制 PHP可变变量 JS中防止浏览器屏蔽window.open PHP操作Session的原理及提升安全性时的一个问题

标签


kanyun worker原理

2013年01月30日

信息获取

主要是有几个plugin函数,依次调用,并把结果发给server

获得主机信息

plugin_local_cpu()
使用命令 sleep %d;top -n 1 -b|grep Cpu|awk '{print $2}' 来检测计算节点(非虚拟机)cpu占用率
plugin_traffic_accounting_info()
获得流量信息,测试不好用

获得宿主机信息

plugin_agent_info(){
    import libvirt 
    conn = libvirt.openReadOnly('qemu:///system')
    hostname = conn.getHostname() #获得主机信息
    conn.listDomainsID() #列出宿主机   
    dom_conn = conn.lookupByID(1) #连接到第一台宿主机
    dom_conn.name() #宿主机名称
    dom_conn.info() #宿主机信息[id,mem_usage,mem_max,vcpu,cpu_time]
    dom_conn.memoryStats() #宿主机内存使用{actual,rss}
}
通过调用libvirt来获取本台机器上虚拟机的使用情况

获得cpu信息

获得cpu使用率方式:

宿主机上cpu两段时间cpu运行时长间隔/主机上实际时长间隔
cpu = 100.0 * self.diffs[dom_id].get_diff() / (self.diffs[dom_id].get_time_pass() * dom_nr_virt_cpu * 1e9)

获得内存信息

获得内存总量和使用量有info()和memoryStats()两个函数。 info()函数取到的内存信息在这里测试时不准确,每次usage和max都是一样的值,而使用memoryStats()取到的是正常的,没有深究区别,先使用后者。

信息发送到server

self.send([msg_type, json.dumps(info)])

通过这句代码将数据发送到server端

其中包括采集到的info信息和本次发送信息的类型msg_type