服务器硬盘剩余内存提醒(适用crmeb短信api)

import subprocess
import requests
import json
def getdisk():

    output = subprocess.check_output(['df', '-h', '/dev/vda1'])
    

    output = output.decode('utf-8').split('\n')
    

    use_percentage = None
    for line in output:
        if line.startswith('/dev/vda1'):
            use_percentage = line.split()[3]
            break
    return use_percentage


disk_usage = getdisk()


print(disk_usage)

def gettoken():
    url = 'http://sms.crmeb.net/api/v2/user/login'
    payload = {
    "access_key": "",#填写你的
    "secret_key": ""#填写你的
    }
    headers = {
    "Content-Type": "application/x-www-form-urlencoded;charset=UTF-8;application/json",
    "content-type": "application/json"
    }
    response = requests.request("POST", url, json=payload, headers=headers)
    token_json = response.json()
    token = token_json["data"]["access_token"]
    print(token)
    return token

token = gettoken()

def get_public_ip():
    url = 'https://api.ipify.org'  # 这是一个提供公共IP查询的API
    
    response = requests.get(url)
    
    if response.status_code == 200:
        ip = response.text.strip()
        print(ip)
        return ip
    else:
        print('获取IP失败')
        return None


public_ip = get_public_ip()

def getmessage(token ,disk_usage ,public_ip):
    url = "http://sms.crmeb.net/api/v2/sms_v2/send"
    payload = {
    "phone": "",#填写你的
    "temp_id": "1019580145",#这个短信模板，我申请好了。
    "param" : {'ip': ":" + public_ip + "。", 'disk': disk_usage}
    }
    headers = {
        "Content-Type": "application/x-www-form-urlencoded;charset=UTF-8;application/json",
        "Authorization": token,
        "content-type": "application/json"
    }

    response = requests.request("POST", url, json=payload, headers=headers)

    print(response.text)

getmessage(token ,disk_usage ,public_ip)

非开发人员直接修改key使用即可。可以设置定时任务 进行每周/每天发送