Python 實作Linux KVM 系統監控名額，很多年前寫的，拿出來是為了幫助同僚，快速學習Python技術

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

<code>#!/usr/bin/env python</code>

<code>#-*-coding:utf8-*-</code>

<code>"""</code>

<code>@Author :  Villiam Sheng</code>

<code>@Group  :  Linux Group</code>

<code>@Date   :  2011-07-18</code>

<code>@Funtion:</code>

<code>            </code><code>Update kvm host status ...</code>

<code>            </code><code>get_nic: Get a week network flow</code>

<code>                </code><code>1,Get Seven days before flow,get maximum value!</code>

<code>                </code><code>2,Get Seven days before flow,get average value!</code>

<code> </code> 

<code>import</code> <code>os,sys,libvirt,socket,shutil,re</code>

<code>from</code>  <code>statvfs </code><code>import</code> <code>F_BLOCKS,F_BAVAIL,F_BSIZE</code>

<code>class</code> <code>kvm_os_status(</code><code>object</code><code>):</code>

<code>    </code><code>def</code> <code>__init__(</code><code>self</code><code>):</code>

<code>        </code><code>self</code><code>.vmm </code><code>=</code> <code>{}</code>

<code>        </code><code>try</code><code>:</code>

<code>            </code><code>self</code><code>.conn </code><code>=</code> <code>libvirt.</code><code>open</code><code>(</code><code>None</code><code>)</code>

<code>        </code><code>except</code> <code>libvirt.libvirtError,e:</code>

<code>            </code><code>print</code> <code>e</code>

<code>    </code><code>def</code> <code>get_mem(</code><code>self</code><code>):</code>

<code>            </code><code>f </code><code>=</code> <code>open</code><code>(</code><code>'/proc/meminfo'</code><code>,</code><code>'r'</code><code>)</code>

<code>            </code><code>for</code> <code>i </code><code>in</code> <code>f.readlines():</code>

<code>                </code><code>if</code> <code>i.find(</code><code>'MemTotal:'</code><code>) !</code><code>=</code> <code>-</code><code>1</code><code>:</code>

<code>                    </code><code>total_mem</code><code>=</code><code>int</code><code>(i.split(</code><code>':'</code><code>)[</code><code>1</code><code>].split(</code><code>'kB'</code><code>)[</code><code>0</code><code>])</code><code>/</code><code>1024</code>

<code>                    </code><code>continue</code>

<code>            </code><code>try</code><code>:</code>

<code>                </code><code>exec_command </code><code>=</code> <code>""" grep "memory" /data*/domains/*/*.xml 2&gt;/dev/null |awk -F "&lt;memory&gt;" '{print $2}'|awk -F "&lt;/memory&gt;" '{print $1}' """</code>

<code>                </code><code>mem </code><code>=</code> <code>os.popen(exec_command).readlines()</code>

<code>                </code><code>act_mem </code><code>=</code> <code>0</code>

<code>                </code><code>for</code> <code>m </code><code>in</code> <code>mem:</code>

<code>                    </code><code>act_mem </code><code>+</code><code>=</code> <code>int</code><code>(m) </code><code>/</code> <code>1024</code>

<code>                </code><code>self</code><code>.vmm[</code><code>'free_mem'</code><code>] </code><code>=</code> <code>total_mem </code><code>-</code> <code>act_mem</code>

<code>            </code><code>except</code> <code>Exception,e:</code>

<code>                </code><code>pass</code>

<code>        </code><code>except</code> <code>Exception,e:</code>

<code>            </code><code>pass</code>

<code>    </code><code>def</code> <code>get_mip(</code><code>self</code><code>):</code>

<code>            </code><code>exec_command </code><code>=</code> <code>"""cat /etc/sysconfig/network-scripts/ifcfg-br0 |grep "IPADDR"|awk -F"=" '{print $2}' 2&gt;/dev/null"""</code>

<code>            </code><code>mip </code><code>=</code> <code>os.popen(exec_command).read().strip()</code>

<code>            </code><code>sock</code><code>=</code><code>socket.socket(socket.AF_INET,socket.SOCK_DGRAM)</code>

<code>                </code><code>sock.connect((mip,</code><code>0</code><code>))</code>

<code>            </code><code>except</code> <code>socket.error,e:</code>

<code>                </code><code>exec_command </code><code>=</code> <code>"""cat /etc/sysconfig/network-scripts/ifcfg-br1 |grep "IPADDR"|awk -F"=" '{print $2}'"""</code>

<code>                </code><code>nip </code><code>=</code> <code>os.popen(exec_command).read().strip()</code>

<code>                </code><code>self</code><code>.vmm[</code><code>'mip'</code><code>] </code><code>=</code> <code>nip</code>

<code>            </code><code>self</code><code>.vmm[</code><code>'mip'</code><code>] </code><code>=</code> <code>sock.getsockname()[</code><code>0</code><code>]</code>

<code>        </code><code>except</code><code>:</code>

<code>    </code><code>def</code> <code>get_disk(</code><code>self</code><code>):</code>

<code>        </code><code>extends </code><code>=</code> <code>[]</code>

<code>        </code><code>disk</code><code>=</code><code>{}</code>

<code>            </code><code>ext_disk </code><code>=</code> <code>os.popen(</code><code>"df -h |awk '{print $1,$6}'|grep -v 'tmpfs'|grep -v 'Filesystem'|grep -v 'sda1'|grep -v 'mfs'|grep -v 'T'"</code><code>).readlines()</code>

<code>        </code><code>if</code> <code>ext_disk </code><code>=</code><code>=</code> <code>"":</code>

<code>            </code><code>self</code><code>.vmm[</code><code>'free_disk'</code><code>] </code><code>=</code> <code>vfs[F_BLOCKS]</code><code>*</code><code>vfs[F_BSIZE]</code><code>/</code><code>1024</code><code>/</code><code>1024</code><code>/</code><code>1024</code>

<code>        </code><code>else</code><code>:</code>

<code>            </code><code>free_disk </code><code>=</code> <code>0</code>

<code>            </code><code>for</code> <code>disk </code><code>in</code> <code>ext_disk:</code>

<code>                </code><code>try</code><code>:</code>

<code>                    </code><code>vfs </code><code>=</code> <code>os.statvfs(disk.split()[</code><code>1</code><code>])</code>

<code>                </code><code>except</code> <code>Exception,e:</code>

<code>                    </code><code>print</code> <code>e</code>

<code>                </code><code>full_space </code><code>=</code> <code>vfs[F_BLOCKS]</code><code>*</code><code>vfs[F_BSIZE]</code><code>/</code><code>1024</code><code>/</code><code>1024</code><code>/</code><code>1024</code>

<code>                </code><code>free_space </code><code>=</code> <code>vfs[F_BAVAIL]</code><code>*</code><code>vfs[F_BSIZE]</code><code>/</code><code>1024</code><code>/</code><code>1024</code><code>/</code><code>1024</code>

<code>                </code><code>imgs </code><code>=</code> <code>os.popen(</code><code>"ls -ls %s/domains/vm*/data*.img 2&gt;/dev/null | awk '{print $1,$6}'"</code> <code>%</code> <code>disk.split()[</code><code>1</code><code>]).readlines()</code>

<code>                </code><code>if</code> <code>imgs:</code>

<code>                    </code><code>for</code> <code>i </code><code>in</code> <code>imgs:</code>

<code>                        </code><code>t_size, f_size </code><code>=</code> <code>i.strip().split()</code>

<code>                        </code><code>free_space </code><code>-</code><code>=</code> <code>int</code><code>(f_size)</code><code>/</code><code>1024</code><code>/</code><code>1024</code><code>/</code><code>1024</code>

<code>                        </code><code>if</code> <code>int</code><code>(t_size) !</code><code>=</code> <code>0</code><code>:</code>

<code>                            </code><code>free_space </code><code>+</code><code>=</code> <code>int</code><code>(t_size)</code><code>/</code><code>1024</code><code>/</code><code>1024</code>

<code>                </code><code>disk</code><code>=</code><code>{disk.split()[</code><code>1</code><code>]:free_space}</code>

<code>                </code><code>for</code> <code>i </code><code>in</code> <code>disk.keys():</code>

<code>                    </code><code>free_disk </code><code>+</code><code>=</code> <code>disk[i]</code>

<code>            </code><code>self</code><code>.vmm[</code><code>'free_disk'</code><code>] </code><code>=</code> <code>free_disk</code>

<code>            </code><code>a </code><code>=</code> <code>os.popen(</code><code>"cat /etc/issue|awk '{print $7}'|grep -v 'Kernel'|grep -v '^$'"</code><code>).readline()</code>

<code>            </code><code>self</code><code>.vmm[</code><code>'os_type'</code><code>] </code><code>=</code> <code>'RHEL%sx64'</code><code>%</code><code>a.strip()</code>

<code>    </code><code>def</code> <code>count(</code><code>self</code><code>):</code>

<code>        </code><code>self</code><code>.vmm[</code><code>'vmm_count'</code><code>] </code><code>=</code> <code>0</code>

<code>            </code><code>for</code> <code>id</code> <code>in</code> <code>self</code><code>.conn.listDomainsID():</code>

<code>                </code><code>dom </code><code>=</code> <code>self</code><code>.conn.lookupByID(</code><code>id</code><code>)</code>

<code>                </code><code>self</code><code>.vmm[</code><code>'vmm_count'</code><code>] </code><code>=</code> <code>self</code><code>.vmm[</code><code>'vmm_count'</code><code>] </code><code>+</code> <code>1</code>

<code>        </code><code>print</code> <code>self</code><code>.vmm</code>

<code>    </code><code>def</code> <code>work(</code><code>self</code><code>):</code>

<code>        </code><code>self</code><code>.get_mem()</code>

<code>        </code><code>self</code><code>.get_disk()</code>

<code>        </code><code>self</code><code>.get_mip()</code>

<code>        </code><code>self</code><code>.count()</code>

<code>if</code> <code>__name__ </code><code>=</code><code>=</code> <code>"__main__"</code><code>:</code>

<code>    </code><code>st </code><code>=</code> <code>kvm_os_status()</code>

<code>    </code><code>st.work()</code>

本文轉自 swq499809608 51CTO部落格，原文連結:http://blog.51cto.com/swq499809608/1549222