背景

由于阿里云oss，cdn消耗錢的速度比較快，在不知道的情況下，服務就被停了，影響比較大。所以想做個監(jiān)控。百度一下阿里云賬戶余額 api 還真有；于是開啟了踩坑之路。

查閱資料創(chuàng)建accessKeyId和accessKeySecret

擼碼階段

要安裝的依賴

sudo pip install aliyun-python-sdk-core  -i https://mirrors.aliyun.com/pypi/simple/sudo pip install  aliyun-python-sdk-bssopenapi -i https://mirrors.aliyun.com/pypi/simple/from aliyunsdkcore import clientfrom aliyunsdkbssopenapi.request.v20171214 import QueryAccountBalanceRequestfrom aliyunsdkcore.profile import region_provider# 檢查賬戶余額def check_account(name, accessKeyId, accessKeySecret, valve, notify_emails):  region_provider.add_endpoint('BssOpenApi', 'cn-hangzhou', 'business.aliyuncs.com')  clt = client.AcsClient(accessKeyId, accessKeySecret, 'cn-hangzhou')  request = QueryAccountBalanceRequest.QueryAccountBalanceRequest()  request.set_accept_format("JSON")  result = clt.do_action_with_exception(request)  print(result)

下面是我封裝的檢查賬戶余額，如果低于閥值就給要通知的人發(fā)郵件。 monitor_balance.py

# -*-coding: UTF-8 -*-'''監(jiān)控阿里云賬戶余額zhouzhongqing2019年12月14日20:21:11sudo pip install aliyun-python-sdk-core  -i https://mirrors.aliyun.com/pypi/simple/sudo pip install  aliyun-python-sdk-bssopenapi -i https://mirrors.aliyun.com/pypi/simple/https://developer.aliyun.com/ask/132002'''import osimport timeimport schedimport smtplibfrom email.mime.text import MIMETextfrom email.header import Headerfrom aliyunsdkcore import clientfrom aliyunsdkbssopenapi.request.v20171214 import QueryAccountBalanceRequestfrom aliyunsdkcore.profile import region_providerimport jsonfrom decimal import Decimal# qq郵箱smtp服務器host_server = 'smtp.qq.com'# sender_qq為發(fā)件人的qq號碼sender_qq = '1030907690@qq.com'# pwd為qq郵箱的授權碼pwd = 'xxxxxx'# 發(fā)件人的郵箱sender_qq_mail = '1030907690@qq.com'# 第一個參數(shù)確定任務的時間，返回從某個特定的時間到現(xiàn)在經(jīng)歷的秒數(shù)# 第二個參數(shù)以某種人為的方式衡量時間schedule = sched.scheduler(time.time, time.sleep);def send_mail(receiver, name, balance, valve):  # 收件人郵箱  # receiver = '1030907690@qq.com'  # 郵件的正文內(nèi)容  mail_content = '您好,目前賬戶%s,余額為%s,低于閥值%s,請知悉!' % (name, balance, valve)  # 郵件標題  mail_title = '%s余額監(jiān)控通知郵件' % (name)  # ssl登錄  smtp = smtplib.SMTP_SSL(host_server)  # set_debuglevel()是用來調(diào)試的。參數(shù)值為1表示開啟調(diào)試模式，參數(shù)值為0關閉調(diào)試模式  smtp.set_debuglevel(0)  smtp.ehlo(host_server)  smtp.login(sender_qq, pwd)  msg = MIMEText(mail_content, "plain", 'utf-8')  msg["Subject"] = Header(mail_title, 'utf-8')  msg["From"] = sender_qq_mail  msg["To"] = receiver  smtp.sendmail(sender_qq_mail, receiver, msg.as_string())  smtp.quit()#解析配置def parse_account():  f = open("monitor.json")  lines = f.read()  data = json.loads(lines)  f.close()  return data# 檢查賬戶余額def check_account(name, accessKeyId, accessKeySecret, valve, notify_emails):  region_provider.add_endpoint('BssOpenApi', 'cn-hangzhou', 'business.aliyuncs.com')  clt = client.AcsClient(accessKeyId, accessKeySecret, 'cn-hangzhou')  request = QueryAccountBalanceRequest.QueryAccountBalanceRequest()  request.set_accept_format("JSON")  result = clt.do_action_with_exception(request)  # print(result)  res_json = json.loads(str(result, encoding="utf-8"))  print(res_json)  if res_json is not None and res_json["Code"] == "200":    availableAmount = res_json["Data"]["AvailableAmount"]    if Decimal(availableAmount) < Decimal(valve):      print("%s低于閥值 " % name)      notify_email_arr = notify_emails.split(",")      for email in notify_email_arr:        send_mail(email, name, availableAmount, valve)def start_check():  try:    data = parse_account();    for item in data:      print("檢查%s" % item["name"])      check_account(item["name"], item["accessKeyId"], item['accessKeySecret'], item['valve'],             item['notifyEmail'])    # send_mail("1030907690@qq.com","恭喜你888","50","100")  except Exception as e:    print("program error %s " % e)  finally:    print("finally print!")def perform_command(cmd, inc):  # 安排inc秒后再次運行自己，即周期運行  schedule.enter(inc, 0, perform_command, (cmd, inc));  os.system(cmd);  start_check();def timming_exe(cmd, inc=60):  # enter用來安排某事件的發(fā)生時間，從現(xiàn)在起第n秒開始啟動  schedule.enter(inc, 0, perform_command, (cmd, inc))  # 持續(xù)運行，直到計劃時間隊列變成空為止  schedule.run()if __name__ == '__main__':  print("start")  print("show time after 60 seconds:");  #timming_exe("echo %time%", 60); # 每間隔多少秒執(zhí)行  timming_exe("date", 60); # 每間隔多少秒執(zhí)行  print("end")'''AvailableAmount	String	可用額度MybankCreditAmount	String	網(wǎng)商銀行信用額度AvailableCashAmount	String	現(xiàn)金余額Currency	String	幣種。取值范圍：CNY：人民幣，USD：美元，JPY：日元CreditAmount	String	信控余額'''