将获取的指标封装成接口提供API请求调用

2024-11-08 技术教程

1.将阿里云的监控指标推送到企业微信

(1)首先需要在项目的根路径下，创建utils包，用于存放项目的其他数据接口；

(2)然后在utils包下，创建一个wechat_send.py模块, 用于给用户封装企业微信的接口，提供给外界调用；

import requestsimport jsonclass Wechat_Info: def __init__(self): self.partyID = '1' self.corpID = 'ww5cfabaf35ce8cd7b' self.secret = 'uiwvmNj8f1IVy3QYrZ62WePGFKA_BsIPmHigq3TRydM' self.agentID = '1000002' self.token = None def __get_token(self, corpid, secret): Url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken" Data = { "corpid": corpid, "corpsecret": secret } r = requests.get(url=Url, params=Data) token = r.json()['access_token'] return token def send_message(self, message): url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={}".format( self.__get_token(self.corpID, self.secret)) data = { "toparty": self.partyID, "msgtype": "text", "agentid": self.agentID, "text": { "content": message }, "safe": "0" } result = requests.post(url=url, data=json.dumps(data)) return result.textif __name__ == '__main__': wechat_info = Wechat_Info() result = wechat_info.send_message('微信测试') print(result)(3)由于partyID、corpID、secret、agentID都是配置信息，需要引入一个读取配置文件的库configparser；

安装：pip install configparser(4)为了管理所有的配置文件还需要创建一个配置文件目录cfg，可以在cfg目录下创建配置文件，如xkd.conf文件；

[Wechat]party_id = 1corp_id = ww5cfabaf35ce8cd7bsecret = uiwvmNj8f1IVy3QYrZ62WePGFKA_BsIPmHigq3TRydMagent_id = 1000002(5)然后可以在utils包下，创建一个const_file.py文件，依赖作为项目中全局常量的引用；

import osPROJECT_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))CONFIG_DIR = os.path.join(PROJECT_DIR, 'cfg')# 指定配置文件的路径CONFIG_FILE = os.path.join(CONFIG_DIR, 'xkd.conf')(6)接着修改wechat_send.py模块接口(配置中的信息都是明文的，在项目开发中，最好将重要的配置信息进行加密，可以使用base64进行加密和解密)；

import requestsimport jsonfrom configparser import ConfigParserfrom utils.const_file import CONFIG_FILEclass Wechat_Info: def __init__(self): self.wechat_info = self.__get_config_info() def __get_config_info(self): parser = ConfigParser() parser.read(CONFIG_FILE) wechat_info = {} wechat_info['party_id'] = parser.get('Wechat', 'party_id') wechat_info['corp_id'] = parser.get('Wechat', 'corp_id') wechat_info['secret'] = parser.get('Wechat', 'secret') wechat_info['agent_id'] = parser.get('Wechat', 'agent_id') return wechat_info def __get_token(self, corpid, secret): Url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken" Data = { "corpid": corpid, "corpsecret": secret } r = requests.get(url=Url, params=Data) token = r.json()['access_token'] return token def send_message(self, message): url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={}".format( self.__get_token(self.wechat_info.get('corp_id'), self.wechat_info.get('secret'))) data = { "toparty": self.wechat_info.get('party_id'), "msgtype": "text", "agentid": self.wechat_info.get('agent_id'), "text": { "content": message }, "safe": "0" } result = requests.post(url=url, data=json.dumps(data)) return result.textif __name__ == '__main__': wechat_info = Wechat_Info() result = wechat_info.send_message('微信测试') print(result)

(7)在utils包下，创建aliyun_monitor.py文件，封装阿里云的云监控数据的接口；

(8)然后编辑xkd.conf配置文件，添加阿里云RAM access key 和 access key secret、region id；

[Wechat]party_id = 1corp_id = wwabdfbc8feeee095asecret = NY2nQE1cavlug_IuyMoRlIZDIOdsDS4KMpo_81XWsloagent_id = 1000002[ALIYUN]access_key = LTAIxdvbuz2MD74Zaccess_key_secret = I2b7O1UJmkjfgHVC4i7Atb8gGXwAbUregion_id = cn-shenzhen(9)编辑aliyun_monitor.py文件；

from aliyunsdkcore import clientfrom aliyunsdkcms.request.v20180308 import QueryMetricListRequestfrom datetime import datetime, timedeltaimport jsonfrom configparser import ConfigParserfrom utils.const_file import CONFIG_FILEclass CloudMonitor: def __init__(self): self.ram_info = self.__get_ram_info() self.clt = client.AcsClient(self.ram_info.get('access_key'), self.ram_info.get('access_key_secret'), self.ram_info.get('region_id')) self.request = QueryMetricListRequest.QueryMetricListRequest() self.last_average = None def __get_ram_info(self): parser = ConfigParser() parser.read(CONFIG_FILE) ram_info = {} ram_info['access_key'] = parser.get('ALIYUN', 'access_key') ram_info['access_key_secret'] = parser.get('ALIYUN', 'access_key_secret') ram_info['region_id'] = parser.get('ALIYUN', 'region_id') return ram_info def __get_start_timestamp(self): start_datetime = datetime.now() - timedelta(minutes=3) start_timestamp = int(start_datetime.timestamp() * 1000) return start_timestamp def get_last_metric(self,instance_id, monitor_key): ''' :param instance_id: ECS是实例ID :param monitor_key: 需要监控的指标 :return: ''' self.request.set_accept_format('json') self.request.set_Project('acs_ecs_dashboard') self.request.set_Metric('{}'.format(monitor_key)) start_time = self.__get_start_timestamp() self.request.set_StartTime(start_time) self.request.set_EndTime(int(datetime.now().timestamp() * 1000)) self.request.set_Dimensions("{'instanceId': '%s'}" % (instance_id)) result = self.clt.do_action_with_exception(self.request) result = json.loads(result) data_str = result.get('Datapoints') data_list = json.loads(data_str) return data_list[-1]['Average']if __name__ == '__main__': monitor = CloudMonitor() result = monitor.get_last_metric('i-wz98bynewgl7gu3jqqb3', 'CPUUtilization') print(result)(10)使用Django定时任务库，需要用到django-crontab；

pip install django-crontab(11)然后在settings文件中添加django-crontab到INSTALLED_APPS；

INSTALLED_APPS = [ 'django.contrib.admin', 'django.contrib.auth', 'django.contrib.contenttypes', 'django.contrib.sessions', 'django.contrib.messages', 'django.contrib.staticfiles', 'users', 'courses', 'teachers', 'schools', 'rest_framework', 'django_crontab',](12)在users APP下创建一个cron.py文件，导入import CloudMonitor和Wechat_Info；

from utils.aliyun_monitor import CloudMonitorfrom utils.wechat_send import Wechat_Infodef send_aliyun_metric_to_wechat(): monitor = CloudMonitor() wechat_info = Wechat_Info() result = monitor.get_last_metric('i-wz98bynewgl7gu3jqqb3', 'CPUUtilization') wechat_info.send_message('当前服务器CPU使用率是：{}'.format(result))(13)在settings文件中配置定时任务CRONJOBS；

CRONJOBS = [ ('* * * * *', 'users.cron.send_aliyun_metric_to_wechat')](14)最后添加定时任务：python manage.py crontab add；2.configparser模块

安装命令行：pip install configparser；

ConfigParser是用来读取配置文件的模块，配置文件的格式跟windows下的ini配置文件相似，可以包含一个或多个section，每个section都有自己的option；

section 用 [sect_name] 表示，每个option是一个键值对，使用分隔符=或:隔开；

在 option 中分隔符两端的空格会被忽略掉；

配置文件使用可以使用#进行注释；

3.django-crontab库

安装命令：pip install django-crontab

django-crontab使用前需要添加到settings文件中的INSTALLED_APPS中；

添加定时任务：python manage.py crontab add，注意如果修改了任务，也需要再次运行此命令；

清除定时任务：python manage.py crontab remove；

显示定时任务：python manage.py crontab show；