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 client
from aliyunsdkbssopenapi.request.v20171214 import QueryAccountBalanceRequest
from 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)

# -*-coding: UTF-8 -*-
'''
監(jiān)控阿里云賬戶余額
zhouzhongqing
2019年12月14日20:21:11
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/
https://developer.aliyun.com/ask/132002
'''
import os
import time
import sched
import smtplib
from email.mime.text import MIMEText
from email.header import Header
from aliyunsdkcore import client
from aliyunsdkbssopenapi.request.v20171214 import QueryAccountBalanceRequest
from aliyunsdkcore.profile import region_provider
import json
from decimal import Decimal
# qq郵箱smtp服務(wù)器
host_server = 'smtp.qq.com'
# sender_qq為發(fā)件人的qq號(hào)碼
sender_qq = '1030907690@qq.com'
# pwd為qq郵箱的授權(quán)碼
pwd = 'xxxxxx'
# 發(fā)件人的郵箱
sender_qq_mail = '1030907690@qq.com'
# 第一個(gè)參數(shù)確定任務(wù)的時(shí)間，返回從某個(gè)特定的時(shí)間到現(xiàn)在經(jīng)歷的秒數(shù)
# 第二個(gè)參數(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,請(qǐng)知悉!' % (name, balance, valve)
  # 郵件標(biāo)題
  mail_title = '%s余額監(jiān)控通知郵件' % (name)
  # ssl登錄
  smtp = smtplib.SMTP_SSL(host_server)
  # set_debuglevel()是用來調(diào)試的。參數(shù)值為1表示開啟調(diào)試模式，參數(shù)值為0關(guān)閉調(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秒后再次運(yùn)行自己，即周期運(yùn)行
  schedule.enter(inc, 0, perform_command, (cmd, inc));
  os.system(cmd);
  start_check();
def timming_exe(cmd, inc=60):
  # enter用來安排某事件的發(fā)生時(shí)間，從現(xiàn)在起第n秒開始啟動(dòng)
  schedule.enter(inc, 0, perform_command, (cmd, inc))
  # 持續(xù)運(yùn)行，直到計(jì)劃時(shí)間隊(duì)列變成空為止
  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	信控余額
'''

[{"name":"恭喜你888","valve": "100","accessKeyId":"xxx","accessKeySecret":"xxx","notifyEmail":1030907690@qq.com}]

nohup python -u monitor_balance.py > nohup.out 2>&1 &