背景
由于阿里云oss,cdn消耗钱的速度比较快,在不知道的情况下,服务就被停了,影响比较大。所以想做个监控。百度一下阿里云账户余额 api
还真有;于是开启了踩坑之路。
查阅资料创建accessKeyId和accessKeySecret
- 官方文档(感觉并不细致) https://help.aliyun.com/document_detail/87997.html"text-align: center">
撸码阶段
要安装的依赖
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") ''' AvailableAmount String 可用额度 MybankCreditAmount String 网商银行信用额度 AvailableCashAmount String 现金余额 Currency String 币种。取值范围:CNY:人民币,USD:美元,JPY:日元 CreditAmount String 信控余额 '''
- 还有个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实现监控阿里云账户余额功能,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢! - 还有个json文件配置
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。
更新日志
- 明达年度发烧碟MasterSuperiorAudiophile2021[DSF]
- 英文DJ 《致命的温柔》24K德国HD金碟DTS 2CD[WAV+分轨][1.7G]
- 张学友1997《不老的传说》宝丽金首版 [WAV+CUE][971M]
- 张韶涵2024 《不负韶华》开盘母带[低速原抓WAV+CUE][1.1G]
- lol全球总决赛lcs三号种子是谁 S14全球总决赛lcs三号种子队伍介绍
- lol全球总决赛lck三号种子是谁 S14全球总决赛lck三号种子队伍
- 群星.2005-三里屯音乐之男孩女孩的情人节【太合麦田】【WAV+CUE】
- 崔健.2005-给你一点颜色【东西音乐】【WAV+CUE】
- 南台湾小姑娘.1998-心爱,等一下【大旗】【WAV+CUE】
- 【新世纪】群星-美丽人生(CestLaVie)(6CD)[WAV+CUE]
- ProteanQuartet-Tempusomniavincit(2024)[24-WAV]
- SirEdwardElgarconductsElgar[FLAC+CUE]
- 田震《20世纪中华歌坛名人百集珍藏版》[WAV+CUE][1G]
- BEYOND《大地》24K金蝶限量编号[低速原抓WAV+CUE][986M]
- 陈奕迅《准备中 SACD》[日本限量版] [WAV+CUE][1.2G]