最近老板给提出一个需要,项目需求大致如下:
1、用树莓派作为网关,底层接多个ZigBee传感节点,网关把ZigBee传感节点采集到的信息通过串口接收汇总,并且发送给上层的HTTP Server;
2、要有数据的反向控制通道,即网关与Server间要保持长连接,采用websocket实现,以此实现给ZigBee传感节点发送控制命令,来实现对ZigBee节点的远程配置操作;3、树莓派网关本身要与上层Server实现交互,上层Server能够看到网关实时的cpu、内存以及网络上行与下行的带宽等等;
前两条需求在前一段时间已经基本实现,等后续有时间完善之后在整理,今天记录一下第三条的实现过程。
感觉第三条需求很像目前公司用到的监控系统的一个小的底层实现,因为前几天无聊刚好搭了个zabbix的环境玩了玩,感觉老板的需求在前端上好像就是类似于zabbix Server上的那种展现形式,但是用zabbix实在感觉不够灵活,其实我也用不明白,只能实现一个类似于top工具的监控脚本吧,先把实时的cpu、内存、网络流量等信息在本地表现出来,等待后续和Server端的朋友联调再说,代码如下:
#!/usr/bin/env python # -*- coding:utf-8 -*- ############################# #__author__ = ‘webber‘ # #create at 2016/12/12 # ############################# import os import sys import time def cpuinfo(): """ get cpuinfo from ‘/proc/stat‘ and calculate the percentage of the cpu occupy. """ f = open(‘/proc/stat‘,‘r‘) cpu = f.readline() f.close() #print "cpuinfo: ", cpu cpu = cpu.split(" ") total = 0 usr = float(cpu[2]) #用户态cpu占用率 _sys = float(cpu[4]) #内核态cpu占用率 for info in cpu: if info.isdigit(): total += float(info) print ‘\033[31mcpu info: \033[0m‘, print ‘usr: %.5f%%‘ % ((usr/total)*100), print ‘ sys: %.5f%%‘ % ((_sys/total)*100) def meminfo(): """ get meminfo from ‘/proc/meminfo‘ and calculate the percentage of the mem occupy used = total - free - buffers - cached """ f = open(‘/proc/meminfo‘,‘r‘) mem = f.readlines() f.close() #print "meminfo", mem total, free, buffers, cached = 0, 0, 0, 0 for info in mem: mem_item = info.lower().split() #print mem_item if mem_item[0] == ‘memtotal:‘: total = float(mem_item[1]) if mem_item[0] == ‘memfree:‘: free = float(mem_item[1]) if mem_item[0] == ‘buffers:‘: buffers = float(mem_item[1]) if mem_item[0] == ‘cached:‘: cached = float(mem_item[1]) used = total - free - buffers - cached print "\033[31mmeminfo: \033[0m", print "total: %.2f GB" % (total/1024/1024), print " used: %.5f%%" % (used/total) def netinfo(): """ get real-time bandwidth """ f = open(‘/proc/net/dev‘,‘r‘) net = f.readlines() f.close() net_item = [] for info in net: if info.strip().startswith("eth0"): net_item = info.strip().split() break # print net_item recv = float(net_item[1]) send = float(net_item[9]) #print "recv:%s " % recv #print "send:%s " % send time.sleep(1) f2 = open(‘/proc/net/dev‘,‘r‘) _net = f2.readlines() f2.close() _net_item = [] for info in _net: if info.strip().startswith("eth0"): _net_item = info.strip().split() break recv_2 = float(_net_item[1]) send_2 = float(_net_item[9]) #print "recv_2:%s " % recv_2 #print "send_2:%s " % send_2 print "\033[31m network info: \033[0m" print "received: %.3f Kb/s" % (recv_2/1024 - recv/1024) print "transmit: %.3f kb/s" % (send_2/1024 - send/1024) def loadavg(): pass def disk(): pass if __name__ == ‘__main__‘: while True: try: os.system(‘clear‘) cpuinfo() print "==============================================" meminfo() print "##############################################" netinfo() time.sleep(5) except KeyboardInterrupt, e: # 这里也可以用信号函数来处理 print ‘‘ print "BYE-BYE" sys.exit(0)
时间: 2024-12-31 03:42:05