说明:
又是坑爹的windows机器。。。
之前写过一个socket去监控windows 流量的工具,但是不直观看不到历史数据。无奈重新选型监控windows网卡流量。
需求: 能直观看到流量历史数据
根据需求来选择开源工具:
- 需要观看历史数据,就需要将流量数据存储到数据库。而监控最好的就是使用时序数据库,所以选择influxdb
- 能直观看到流量, 就需要图表工具。而grafana正好可以结合influxdb使用,两者天衣无缝
解决思路:
windows服务器上通过python脚本获取网卡流量信息,然后通过influxdb http api写入influxdb。 在grafana中添加influxdb的源数据,然后图表显示
思路出来了,剩下的就是动手开干了。。。
实践:
influxdb安装略。。。
grafana安装略。。。
python获取网卡流量脚本:
monitor_client.py
import psutil
import os
import time
import ConfigParser
import requests
from requests.auth import HTTPBasicAuth
def get_net_out():
bytes_sent = psutil.net_io_counters().bytes_sent
return bytes_sent
def get_now_io():
old_sent = get_net_out()
time.sleep(1)
new_sent = get_net_out()
return (new_sent - old_sent)/1024.0/1024.0
if __name__ == '__main__':
conf_file = os.path.join(os.path.abspath(os.path.dirname(__file__)), 'monitor.conf')
cf = ConfigParser.ConfigParser()
cf.read(conf_file)
cf_items = dict( cf.items('main') if cf.has_section('main') else {})
while True:
posturl = 'http://%s:%s/write?db=%s'%(cf_items.get('influx_host'), cf_items.get('influx_port'), cf_items.get('influx_db'))
data = 'host_net,host=%s,ip=%s out=%s'%(cf_items.get('hostname'), cf_items.get('ip'), get_now_io())
response = requests.post(posturl, data=data, auth=HTTPBasicAuth(cf_items.get('influx_user'), cf_items.get('influx_passwd')))
time.sleep(600)
monitor.conf
[main]
influx_host= 192.168.2.221
influx_db = test
influx_user = test
influx_passwd = 123456
influx_port = 8086
hostname = app01.com
ip = 192.168.2.21
脚本通过monitor.conf配置文件获取连接influxdb的参数
使用pyinstall打包exe文件
因为如果直接将py文件放到服务器上,需要在每台机器上安装python环境,比较麻烦。所以直接将py脚本打包成exe
pyinstall.exe -F -w monitor_client.py
然后将exe文件和配置文件放到服务器上,exe和配置文件必须在同一级目录