python实现监控阿里云账户余额功能
作者:愤怒的苹果ext 发布时间:2022-08-19 23:43:32
背景
由于阿里云oss,cdn消耗钱的速度比较快,在不知道的情况下,服务就被停了,影响比较大。所以想做个监控。百度一下阿里云账户余额 api
还真有;于是开启了踩坑之路。
查阅资料创建accessKeyId和accessKeySecret
官方文档(感觉并不细致) https://help.aliyun.com/document_detail/87997.html?spm=a2c6h.13066369.0.0.59e4581eaxXH1O
sdk https://developer.aliyun.com/sdk?spm=5176.12818093.resource-links.dsdk_platform.488716d022QXo0
看了官方文档后还是有点懵逼,后面Google了这个关键字
QueryAccountBalanceRequest
才看到真正的样例代码https://developer.aliyun.com/ask/132002(感觉这块资料很少呀,aliyun-python-sdk-bssopenapi
居然没写在sdk安装列表里面,在社区找到的)。创建accessKeyId,鼠标悬停到右上角
撸码阶段
要安装的依赖
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)
下面是我封装的检查账户余额,如果低于阀值就给要通知的人发邮件。 monitor_balance.py
# -*-coding: UTF-8 -*-
'''
监控阿里云账户余额
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服务器
host_server = 'smtp.qq.com'
# sender_qq为发件人的qq号码
sender_qq = '1030907690@qq.com'
# pwd为qq邮箱的授权码
pwd = 'xxxxxx'
# 发件人的邮箱
sender_qq_mail = '1030907690@qq.com'
# 第一个参数确定任务的时间,返回从某个特定的时间到现在经历的秒数
# 第二个参数以某种人为的方式衡量时间
schedule = sched.scheduler(time.time, time.sleep);
def send_mail(receiver, name, balance, valve):
# 收件人邮箱
# receiver = '1030907690@qq.com'
# 邮件的正文内容
mail_content = '您好,目前账户%s,余额为%s,低于阀值%s,请知悉!' % (name, balance, valve)
# 邮件标题
mail_title = '%s余额监控通知邮件' % (name)
# ssl登录
smtp = smtplib.SMTP_SSL(host_server)
# set_debuglevel()是用来调试的。参数值为1表示开启调试模式,参数值为0关闭调试模式
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用来安排某事件的发生时间,从现在起第n秒开始启动
schedule.enter(inc, 0, perform_command, (cmd, inc))
# 持续运行,直到计划时间队列变成空为止
schedule.run()
if __name__ == '__main__':
print("start")
print("show time after 60 seconds:");
#timming_exe("echo %time%", 60); # 每间隔多少秒执行
timming_exe("date", 60); # 每间隔多少秒执行
print("end")
'''
AvailableAmountString可用额度
MybankCreditAmountString网商银行信用额度
AvailableCashAmountString现金余额
CurrencyString币种。取值范围:CNY:人民币,USD:美元,JPY:日元
CreditAmountString信控余额
'''
还有个json文件配置
monitor.json
里面分别代表的是名称,发起邮件通知账户余额阀值,id,密钥,通知的邮箱(可以多个,逗号
,
分割)。
[{"name":"恭喜你888","valve": "100","accessKeyId":"xxx","accessKeySecret":"xxx","notifyEmail":1030907690@qq.com}]
运行效果
如果是正式环境部署的话可以用这个命令,可以后台运行,日志输出到 nohup.out:
nohup python -u monitor_balance.py > nohup.out 2>&1 &
总结
以上所述是小编给大家介绍的python实现监控阿里云账户余额功能网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
来源:https://blog.csdn.net/baidu_19473529/article/details/103544403


猜你喜欢
- 如何在PYTHON里运用私有属性和方法class File:def __init__(self, name):self.name = nam
- 就来总结一下简单的东西备注:一下的方法都是包裹在一个EventUtil对象里面的,直接采用对象字面量定义方法了。。。①添加事件方法addHa
- 本文不涉及分类器、训练识别器等算法原理,仅包含对其应用(未来我也会写自己对机器学习算法原理的一些观点和了解)首先我们需要知道的是利用现有框架
- 赋值:其实就是对象的引用(相当于取别名)。浅拷贝(copy):拷贝父对象,不会拷贝对象内部的子对象,会引用子对象。深拷贝(deepcopy)
- 级联样式表在13年前被引入,而且被广泛使用的CSS 2.1 标准在11年前被创建,显然我们现在已经与当年相差千里了。相当了不起的是期间网站开
- 1.如果每页都增加打印时间,又如何设置?打印时间的,你可以参考 for(var i=0;i<page.length;i++)
- 存储和读取ASCII码形式的byte数据Python可以存byte数据到txt,但不要用str的方式直接存,转成数字列表储存,这样方便读取L
- 查看安装的python版本号可以使用【python --version】命令。具体方法:首先按【win+r】组合键打开运行;然后输入cmd,
- <?php $link=mysql_connect("localhost",&
- 还有多少耿直boy和我一样在等待微信官方送上一顶圣诞帽?最后知道真相的我眼泪掉下来……(还蒙在鼓里的同学请在微信最上方的搜索栏自行搜索『圣诞
- 本文实例讲述了Python编程对列表中字典元素进行排序的方法。分享给大家供大家参考,具体如下:内容目录:1. 问题起源2. 对列表中的字典元
- 测试环境为Windows 10 系统,Python3.7,转换需要提前安装pydub、ffmpeg,安装和加入环境变量配置方法自行解决,至于
- Python数据库接口支持非常多的数据库,你可以选择适合你项目的数据库:GadFlymSQL MySQL PostgreSQL Micros
- 1、登录mysqlmysql -uroot -p2、先查询都有哪些用户select host,user from mysql.user;红色
- Mysql调优Explain工具详解以及实战演练 Explain工具介绍Explain分析示例explain 两个变种explain中的列
- 说明:复制表(只复制结构,源表名:a 新表名:b) select * into b from a where 1<>1说明:拷贝
- 矩阵增加行np.row_stack() 与 np.column_stack()import numpy as npa = np.array(
- 在使用数据库的时候,难免要在使用过程中进行删除的操作,如果是使用int类型的字段,令其自增长,这是个最简单的办法,但是后果会有些不是你想要的
- 给静态网页加密的方法有很多,有的简单有的复杂。前两天看见有人问静态网页加密问题,就写了这个代码思路:加密时:先把用户的密钥A用md5加密为B
- 以行的形式读出一个文件最简单的方式是使用文件对象的readline()、readlines()和xreadlines()方法。Python2