由于上證所，深交所level1，level2金融數據服務器在上午9：00開始到11：30和下午13：00開始到15：30一共大約5個小時的時間內流量比較大所以被監(jiān)控服務器的網絡流速算是一個被監(jiān)控的重要指標。可以通過累加一段時間內各個網卡的上行，下行流量除以這個時間間隔計算出這段時間內的平均網速，我現在的采集頻率是1分鐘采集一次，在實際開盤期間運行過程中得到的網速監(jiān)控信息用還是比較準確的，都保持在5M/S左右的速度，有時候在平時非服務期看見某臺服務器的內網網卡網速達到5M/S ，果然就是有人在大手筆傳輸。
獨立的監(jiān)控腳本是返回一個列表嵌套元組的數據結構，最后再匯總成一個完整的XML數據島，為了調試方便腳本的每一個中間結果都導出到一個臨時文本中。
運行以下腳本要確定你的linux裝了ethtool工具，在ubuntu2.6.27-7-server，ubuntu22.6.27.19-5-default，suse 2.6.27.19-5-default 測試通過。
代碼：
-
-
- import re
- import os
- import time
-
- import utils
- def sortedDictValues3(adict):
- keys = adict.keys()
- keys.sort()
- return map(adict.get, keys)
-
- def run():
- if utils.isLinux() == False:
- return [('ifconfig_collect os type error','this is windows')]
-
- if os.path.isfile('./oldifconfig'):
- fileold = open('./oldifconfig', 'r')
- fileold.seek(0)
-
- (oldtime, fileoldcontent) = fileold.read().split('#')
- fileold.close;
- netcard = {}
- tempstr = ''
- key = ''
- for strline in fileoldcontent.split('\n'):
- reobj = re.compile('^lo*.')
- if reobj.search(strline):
- break;
- reobj = re.compile('^eth*.')
- if reobj.search(strline):
- key = strline.split()[0]
- tempstr = tempstr + strline + '\n'
- netcard[key] = tempstr
- RXold = {}
- TXold = {}
- for key,value in netcard.items():
- tempsplit = value.split('\n')
- netcard[key] = ''
- for item in tempsplit:
- item = item + '<br>'
- netcard[key] = netcard[key] + item
- tempcount = 1
- for match in re.finditer("(bytes:)(.*?)( \()", item):
- if tempcount == 1:
- RXold[key] = match.group(2)
- tempcount = tempcount + 1
- elif tempcount == 2:
- TXold[key] = match.group(2)
- netcard[key] = netcard[key] + 'net io percent(bytes/s): 0 <br>'
-
-
- os.system('ifconfig > ifconfigtemp')
- file = open('./ifconfigtemp','r');
- fileold = open('./oldifconfig', 'w')
- temptimestr = str(int(time.time()));
- fileold.write(temptimestr)
- fileold.write('#')
- file.seek(0)
- fileold.write(file.read())
- fileold.close()
- returnkeys = []
- returnvalues = []
- netcard = {}
- tempcountcard = 0
- file.seek(0)
- key = ''
- for strline in file.readlines():
- reobj = re.compile('^lo*.')
- if reobj.search(strline):
- break;
- reobj = re.compile('^eth*.')
- if reobj.search(strline):
- key = strline.split()[0]
- netcard[key] = ''
- netcard[key] = netcard[key] + strline
- newnetcard = {}
- file.seek(0)
- key = ''
- for strline in file.readlines():
- reobj = re.compile('^lo*.')
- if reobj.search(strline):
- break;
- if re.search("^eth", strline):
- templist = strline.split()
- key = templist[0]
- newnetcard[key] = ''
- newnetcard[key] = templist[4] + newnetcard[key] + ' '
- if re.search("^ *inet ", strline):
- templist = strline.split()
- newnetcard[key] = templist[1][5:] + ' ' + newnetcard[key] + ' '
- for key,value in newnetcard.items():
-
- os.system('ethtool %s > ethtooltemp'%(key))
- file = open('./ethtooltemp','r');
- tempethtooltemplist = file.read().split('\n\t')
- file.close
- if re.search("yes", tempethtooltemplist[-1]):
- templist = newnetcard[key].split()
- newnetcard[key] = templist[0] + ' runing! ' + templist[1]
- else:
- templist = newnetcard[key].split()
- if len(templist) > 1:
- newnetcard[key] = templist[0] + ' stop! ' + templist[1]
- else:
- newnetcard[key] = 'stop! ' + templist[0]
- file.close()
- RX = {}
- TX = {}
- for key,value in netcard.items():
- tempsplit = value.split('\n')
- netcard[key] = ''
- for item in tempsplit:
- item = item + '<br>'
- netcard[key] = netcard[key] + item
- tempcount = 1
- for match in re.finditer("(bytes:)(.*?)( \()", item):
- if tempcount == 1:
- RX[key] = str(int(match.group(2)) - int(RXold[key]))
- tempcount = tempcount + 1
- elif tempcount == 2:
- TX[key] = str(int(match.group(2)) - int(TXold[key]))
- divtime = float(int(time.time()) - int(oldtime))
- if divtime == 0:
- rate = (float(TX[key]) + float(RX[key]))
- else:
- rate = (float(TX[key]) + float(RX[key]))/(divtime)
- if rate == 0:
- newnetcard[key] = '0' + ' ' + newnetcard[key]
- else:
- newnetcard[key] = '%.2f'%rate + ' ' + newnetcard[key]
- return zip(['order'], ['48']) + newnetcard.items();
- else:
- os.system('ifconfig > ifconfigtemp')
- file = open('./ifconfigtemp','r');
- fileold = open('./oldifconfig', 'w')
- temptimestr = str(int(time.time()));
- fileold.write(temptimestr)
- fileold.write('#')
- file.seek(0)
- fileold.write(file.read())
- fileold.close()
-
- netcard = {}
- file.seek(0)
- key = ''
- for strline in file.readlines():
- reobj = re.compile('^lo*.')
- if reobj.search(strline):
- break;
- reobj = re.compile('^eth*.')
- if reobj.search(strline):
- key = strline.split()[0]
- netcard[key] = ''
- netcard[key] = netcard[key] + strline
- RX = {}
- TX = {}
-
- key = ''
- newnetcard = {}
- file.seek(0)
- for strline in file.readlines():
- reobj = re.compile('^lo*.')
- if reobj.search(strline):
- break;
- if re.search("^eth", strline):
- templist = strline.split()
- key = templist[0]
- newnetcard[key] = templist[4] + ' '
- if re.search("^ *inet ", strline):
- templist = strline.split()
- newnetcard[key] = newnetcard[key] + templist[1][5:] + ' '
- for key,value in newnetcard.items():
- os.system('ethtool %s > ethtooltemp'%(key))
- file = open('./ethtooltemp','r');
- tempethtooltemplist = file.read().split('\n')
- file.close
- if re.search("yes", tempethtooltemplist[-1]):
- newnetcard[key] = newnetcard[key] + 'runing!'
- else:
- newnetcard[key] = newnetcard[key] + 'stop!'
- file.close()
- for key,value in netcard.items():
- tempsplit = value.split('\n')
- netcard[key] = ''
- for item in tempsplit:
- item = item + '<br>'
-
- netcard[key] = netcard[key] + item
- tempcount = 1
- for match in re.finditer("(bytes:)(.*?)( \()", item):
- if tempcount == 1:
- RX[key] = match.group(2)
- tempcount = tempcount + 1
- elif tempcount == 2:
- TX[key] = match.group(2)
- netcard[key] = netcard[key] + 'net io percent(bytes/s): 0 <br>'
- newnetcard[key] = newnetcard[key] + ' ' + '0 <br>'
- return zip(['order'], ['48']) + newnetcard.items();
- if __name__ == '__main__':
- print run()
使用例子：
每一個列表元素元組里面第二個元素第一個字段為網速 Bytes/S，例如eth1網卡的網速就是3.3KB/s，eth0網速是2.9KB/s，今天是周六這個流量很正常