first commit

.gitignore

@@ -0,0 +1,2 @@
+__pycache__
+config.ini.bak

README.MD

@@ -0,0 +1,41 @@
+# Linux开发板运行状态监控及推送
+
+## 主要功能
+
+- CPU占用异常报警
+- 内存占用异常报警
+- 温度异常报警
+- 网络异常自动重启(未测试)
+- 磁盘占用异常报警
+
+## 使用方法
+
+### 注册微信企业号
+
+用于免费接受推送消息
+
+教程地址：<https://github.com/easychen/wecomchan>
+
+拿到`企业Id`,`应用secret`,`应用ID`就行
+
+### 填写配置文件
+
+根据config.ini中注释文件填写对应参数
+
+### 安装python3及依赖
+
+略(不会连这个都不会吧)
+
+### 运行程序
+
+注意别用root用户运行
+
+python3 main.py
+
+### 设置为自启动服务
+
+仅针对debian系，包括debian，ubuntu等
+
+修改opi4monitor.service
+
+注册服务

config.ini

@@ -0,0 +1,38 @@
+# 参数没做合法性检测
+[wechatpush]
+# 企业微信企业ID
+corpid = wwxxxxxxxxxxxxxxxx
+# 自建应用agentid
+agentid = 1xxxxxx
+# 自建应用secret
+secret = xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
+# （目前没用）消息接收用户id，如果多个用户用英文','隔开，@all表示所有人
+userid = @all
+
+[monitor]
+# cpu温度文件位置，不同开发板都不一样，这里以orangepi4 armbian系统为例
+cpu_temperature_file = /etc/armbianmonitor/datasources/soctemp
+# cpu温度原始值的精度，比如读出来是55000，实际是55摄氏度，就填1000
+cpu_temperature_scaler = 1000
+# 要监控的磁盘挂载目录,df命令能查看
+disk_mount_point = /mnt/disk3
+# 用于检测网络连通性的网址或ip，如www.baidu.com
+ping_siteorip = 192.168.123.1
+# 总体检测间隔，秒
+time_interval = 3600
+
+[threshold]
+# cpu温度阈值，摄氏度
+cpu_temperature_threshold = 60
+# cpu总占用率阈值，%
+cpu_usage_threshold = 30
+# RAM空闲容量阈值，MB
+ram_free_threshold = 300
+# 网络检测重启前失败次数
+ping_error_count_threshold = 3
+# 磁盘空闲容量阈值，GB
+disk_free_threshold = 200
+
+[log]
+# 日志保存位置，需要自行新建并赋予权限
+log_file_path = /var/log/orangepi4monitor.log

linuxmonitor.service

@@ -0,0 +1,11 @@
+[Unit]
+Description=linux monitor and push
+After=network.target
+
+[Service]
+Type=simple
+User=dev
+ExecStart=python /home/dev/linuxmonitor/main.py > /dev/null 2>&1
+
+[Install]
+WantedBy=multi-user.target

main.py

@@ -0,0 +1,214 @@
+# -*- coding: utf-8 -*-
+import os
+import time
+import logging
+import wechatpush
+import psutil
+import ping3
+from configparser import ConfigParser
+
+# Return CPU temperature as a character string
+
+
+def getCPUtemperature(file, scaler):
+    cputemp = 0
+    rawline = os.popen('cat %s' % file).readline()
+    try:
+        cputemp = int(rawline) // int(scaler)
+    except Exception as ex:
+        logging.error("%s", ex)
+        cputemp = 0
+
+    return cputemp
+
+# Return RAM information (unit=kb) in a list
+# Index 0: total RAM
+# Index 1: used RAM
+# Index 2: free RAM
+
+
+def getRAMinfo():
+    p = os.popen('free')
+    i = 0
+    while 1:
+        i = i + 1
+        line = p.readline()
+        if i == 2:
+            return (line.split()[1: 4])
+
+# Return % of CPU used by user as a character string
+
+
+def getCPUuse():
+    # cpuusagestr = os.popen("top -n1 | awk '/Cpu\(s\):/ {print $2}'").readline()
+    # logging.info(cpuusagestr)
+    cpuusagefloat = psutil.cpu_percent()
+    return cpuusagefloat
+
+# Return information about disk space as a list (unit included)
+# Index 0: total disk space
+# Index 1: used disk space
+# Index 2: remaining disk space
+# Index 3: percentage of disk used
+
+
+def getDiskSpace(mount_point):
+    p = os.popen("df %s" % mount_point)
+    i = 0
+    while 1:
+        i = i + 1
+        line = p.readline()
+        if i == 2:
+            return (line.split()[1: 5])
+
+
+def get_info():
+
+    # CPU informatiom
+    CPU_temp = getCPUtemperature()
+    CPU_usage = getCPUuse()
+
+    # RAM information
+    # Output is in kb, here I convert it in Mb for readability
+    RAM_stats = getRAMinfo()
+    RAM_total = round(int(RAM_stats[0]) / 1024, 1)
+    RAM_used = round(int(RAM_stats[1]) / 1024, 1)
+    RAM_free = round(int(RAM_stats[2]) / 1024, 1)
+
+    # Disk information
+    DISK_stats = getDiskSpace()
+    DISK_total = DISK_stats[0]
+    DISK_used = DISK_stats[1]
+    DISK_left = DISK_stats[2]
+    DISK_perc = DISK_stats[3]
+
+    logging.info(
+        "\nLocal Time {timenow} \n"
+        "CPU Temperature = {CPU_temp}\n"
+        "CPU Use = {CPU_usage} %\n"
+        "RAM Total = {RAM_total} MB\n"
+        "RAM Used = {RAM_used} MB\n"
+        "RAM Free = {RAM_free} MB\n\n"
+        "DISK Total Space = {DISK_total}B\n"
+        "DISK Used Space = {DISK_used}B\n"
+        "DISK Left Space = {DISK_left}B\n"
+        "DISK Used Percentage = {DISK_perc}\n"
+        "".format(
+            timenow=time.asctime(time.localtime(time.time())),
+            CPU_temp=CPU_temp,
+            CPU_usage=CPU_usage,
+            RAM_total=str(RAM_total),
+            RAM_used=str(RAM_used),
+            RAM_free=str(RAM_free),
+            DISK_total=str(DISK_total),
+            DISK_used=str(DISK_used),
+            DISK_left=str(DISK_left),
+            DISK_perc=str(DISK_perc),
+        )
+    )
+
+
+CPU_temp_flag = 0
+CPU_usage_flag = 0
+RAM_free_flag = 0
+DISK_left_flag = 0
+ping_flag = 99
+
+
+def monitor(corpid, agentid, secret, cpu_temperature_file, cpu_temperature_scaler, disk_mount_point,
+                ping_siteorip, cpu_temperature_threshold, cpu_usage_threshold, ram_free_threshold, 
+                ping_error_count_threshold, disk_free_threshold):
+    global CPU_temp_flag
+    global CPU_usage_flag
+    global RAM_free_flag
+    global DISK_left_flag
+    global ping_flag
+
+    # cpu温度监控
+    if CPU_temp_flag == 0:
+        CPU_temp = getCPUtemperature(cpu_temperature_file,cpu_temperature_scaler)
+        logging.info("cpu temperature:%d C" % CPU_temp)
+        # 是否超过55度
+        if CPU_temp > int(cpu_temperature_threshold):
+            CPU_temp_flag = 10
+            wechatpush.send_to_wecom(
+                "cpu temperature:%d C" % CPU_temp, corpid, agentid, secret)
+    elif CPU_temp_flag > 0:
+        CPU_temp_flag = CPU_temp_flag - 1
+
+    # cpu占用监控
+    CPU_usage = getCPUuse()
+    logging.info("cpu usage:{CPU_usage} %".format(
+            CPU_usage=str(CPU_usage)))
+    if CPU_usage > int(cpu_usage_threshold):
+        wechatpush.send_to_wecom("cpu usage:{CPU_usage} %".format(
+            CPU_usage=str(CPU_usage)), corpid, agentid, secret)
+    RAM_stats = getRAMinfo()
+    RAM_free = round(int(RAM_stats[2]) / 1024, 1)
+    if RAM_free < int(ram_free_threshold):
+        wechatpush.send_to_wecom("ram free:%d MB" %
+                                 RAM_free, corpid, agentid, secret)
+    # 磁盘监控
+    if DISK_left_flag == 0:
+        DISK_stats = getDiskSpace(disk_mount_point)
+        DISK_left = int(DISK_stats[2]) // 1000000
+        logging.info("disk free:%d GB" %DISK_left)
+        if DISK_left < int(disk_free_threshold):
+            DISK_left_flag = 10
+            wechatpush.send_to_wecom("disk free:%d GB" %
+                                     DISK_left, corpid, agentid, secret)
+    elif DISK_left_flag > 0:
+        DISK_left_flag = DISK_left_flag - 1
+
+    # 网络监控
+    logging.info("ping_flag:%d" % ping_flag)
+    pingresult = ping3.ping(ping_siteorip)
+    if pingresult is None:
+        logging.info("network error")
+        wechatpush.send_to_wecom("network error", corpid, agentid, secret)
+        if ping_flag != 99:
+            ping_flag = ping_flag + 1
+            if ping_flag >= int(ping_error_count_threshold):
+                logging.info("network error,reboot now!")
+                # TODO:添加重启命令
+                ping_flag = 99
+                wechatpush.send_to_wecom(
+                    "network error,reboot now!", corpid, agentid, secret)
+    else:
+        logging.info("ping status:{}".format(pingresult))
+        ping_flag = 0
+
+
+if __name__ == '__main__':
+    current_dir = os.path.dirname(os.path.abspath(__file__))
+    # 加载参数
+    config = ConfigParser()
+    config_file_path = os.path.join(current_dir,'config.ini')
+    config.read(config_file_path, encoding='utf-8')
+    corpid = config['wechatpush']['corpid']
+    agentid = config['wechatpush']['agentid']
+    secret = config['wechatpush']['secret']
+    cpu_temperature_file = config['monitor']['cpu_temperature_file']
+    cpu_temperature_scaler = config['monitor']['cpu_temperature_scaler']
+    disk_mount_point = config['monitor']['disk_mount_point']
+    ping_siteorip = config['monitor']['ping_siteorip']
+    time_interval = config['monitor']['time_interval']
+    cpu_temperature_threshold = config['threshold']['cpu_temperature_threshold']
+    cpu_usage_threshold = config['threshold']['cpu_usage_threshold']
+    ram_free_threshold = config['threshold']['ram_free_threshold']
+    ping_error_count_threshold = config['threshold']['ping_error_count_threshold']
+    disk_free_threshold = config['threshold']['disk_free_threshold']
+    log_file_path = config['log']['log_file_path']
+
+    # get info
+    logger_file = os.path.join(log_file_path)
+    handlers = [logging.FileHandler(logger_file, mode='w')]
+    logging.basicConfig(format='%(asctime)s - %(pathname)s[line:%(lineno)d] '
+                        '- %(levelname)s: %(message)s',
+                        level=logging.INFO,
+                        handlers=handlers)
+    while(True):
+        monitor(corpid, agentid, secret, cpu_temperature_file, cpu_temperature_scaler, disk_mount_point,
+                ping_siteorip, cpu_temperature_threshold, cpu_usage_threshold, ram_free_threshold, 
+                ping_error_count_threshold, disk_free_threshold)
+        time.sleep(int(time_interval))  # Time interval for obtaining resources

requirements.txt

@@ -0,0 +1,3 @@
+ping3==4.0.3
+psutil==5.9.1
+requests==2.22.0