通过阿里云api查询账户余额、日流水、N日内平均流水

#!/usr/bin/env python
#coding=utf-8
#阿里云余额告警接口
from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkbssopenapi.request.v20171214.QueryAccountBalanceRequest import QueryAccountBalanceRequest
from aliyunsdkbssopenapi.request.v20171214.QueryAccountTransactionsRequest import QueryAccountTransactionsRequest
import locale
import time,datetime
import os,requests,hashlib
import warnings
import json
import numpy as np

#别名 = AcsClient('<access_key_id>','<access_key_secret>','cn-hangzhou')
maxbon = AcsClient('<access_key_id>','<access_key_secret>','cn-hangzhou')

#获取前n天的日期列表
def get_nday_list(n):
    import datetime
    before_n_days = []
    for i in range(1, n + 1)[::-1]:
        before_n_days.append(str(datetime.date.today() - datetime.timedelta(days=i)))
    return before_n_days

#获取账户余额
def get_response(account,min_quota):
    request = QueryAccountBalanceRequest()
    request.set_accept_format('json')
    response = account.do_action_with_exception(request)
#print(response)
        AvailableAmount = response.split('"')[5]
        locale.setlocale( locale.LC_ALL, 'en_US.UTF-8' )
    int_AvailableAmount = int(locale.atof(AvailableAmount))
        if int_AvailableAmount < int(min_quota):
                return int_AvailableAmount
        else:
                return 0

#获取指定日期内流水
def get_Transactions(account,start_date,end_date,PageSize):
    request = QueryAccountTransactionsRequest()
    request.set_accept_format('json')
    request.set_PageSize(PageSize)
    request.set_CreateTimeStart(start_date+"T00:00:00Z")
    request.set_CreateTimeEnd(end_date+"T00:00:00Z")
    response = account.do_action_with_exception(request)
    json_response = json.loads(response)
    lenth = len(json_response["Data"]["AccountTransactionsList"]["AccountTransactionsList"])
#    print(start_date,end_date)
#    print lenth
    #求和
    Amounts = []
    for i in range(lenth):
        Amounts.append(json_response["Data"]["AccountTransactionsList"]["AccountTransactionsList"][i]["Amount"])
    sum_Transactions=sum([float(each_e) for each_e in Amounts])
    return sum_Transactions

#前n-1日平均流水查询
def get_nday_Transactions(account,nday,PageSize=300):
    global Transactions_list
    dates = get_nday_list(nday)
    Transactions_array = []
    i = 0;x = i + 1
    while x < len(dates):
        Transactions_array.append(round(get_Transactions(account,dates[i],dates[x],PageSize),2))
#        time.sleep(10)
        i += 1;x = i + 1
    if len(dates) > 2:
        Transactions_list = Transactions_array
        Transactions_array.remove(max(Transactions_array)) #去掉一个最大值
    mean = round(np.mean(np.array(Transactions_array,np.float)),2) #求平均值
    return dates,mean,Transactions_list

#参数1：阿里云账户
#参数2：前面定义的别名
#参数3：余额告警最小阈值
def check_status(ali_id,account,min_quota):
        status = get_response(account,min_quota)
        message = '【告警】阿里云帐户余额低于'+str(min_quota)+',请及时充值，帐户：'+ali_id+'，当前余额：'+str(status)+'元，https://account.aliyun.com/login/login.htm'
        if status != 0:
        print ali_id,status
        print message

#流水查询
#参数1：阿里云账户
#参数2：前面定义的别名
#参数3：N天内的平均流水
def check_Transactions(ali_id,account,nday):
    a = get_nday_Transactions(account,nday)
    b = get_nday_Transactions(account,2)[1]
    c = int(((b - a[1])/a[1])*100)
    message = str(a[2])+'\r\n【流水异常】账户：'+ali_id+'，前5日平均流水：'+str(a[1])+'，昨日流水：'+str(b)+'，增长率：'+str(c)+'%'
    if c > 50:
        print(message)
    else:
        print('OK')
        print(message)

#余额查询
check_status('maxbon',maxbon,5000)

#流水查询
check_Transactions('maxbon',maxbon,6)