美文网首页python学习
Python学习打call第六十七天:将获取的指标封装成接口提供

Python学习打call第六十七天:将获取的指标封装成接口提供

作者: 暖A暖 | 来源:发表于2019-04-21 14:52 被阅读0次

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

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

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

    import requests
    import json
    
    class 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.text
    if __name__ == '__main__':
        wechat_info = Wechat_Info()
        result = wechat_info.send_message('微信测试')
        print(result)
    
    • (3)由于partyIDcorpIDsecretagentID都是配置信息,需要引入一个读取配置文件的库configparser
    安装:
    pip install configparser
    
    • (4)为了管理所有的配置文件还需要创建一个配置文件目录cfg,可以在cfg目录下创建配置文件,如xkd.conf文件;
    [Wechat]
    party_id = 1
    corp_id = ww5cfabaf35ce8cd7b
    secret = uiwvmNj8f1IVy3QYrZ62WePGFKA_BsIPmHigq3TRydM
    agent_id = 1000002
    
    • (5)然后可以在utils包下,创建一个const_file.py文件,依赖作为项目中全局常量的引用;
    import os
    PROJECT_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 requests
    import json
    from configparser import ConfigParser
    from utils.const_file import CONFIG_FILE
    
    class 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.text
    if __name__ == '__main__':
        wechat_info = Wechat_Info()
        result = wechat_info.send_message('微信测试')
        print(result)
    
    • (7)在utils包下,创建aliyun_monitor.py文件,封装阿里云的云监控数据的接口;

    • (8)然后编辑xkd.conf配置文件,添加阿里云RAM access keyaccess key secretregion id

    [Wechat]
    party_id = 1
    corp_id = wwabdfbc8feeee095a
    secret = NY2nQE1cavlug_IuyMoRlIZDIOdsDS4KMpo_81XWslo
    agent_id = 1000002
    
    [ALIYUN]
    access_key = LTAIxdvbuz2MD74Z
    access_key_secret = I2b7O1UJmkjfgHVC4i7Atb8gGXwAbU
    region_id = cn-shenzhen
    
    • (9)编辑aliyun_monitor.py文件;
    from aliyunsdkcore import client
    from aliyunsdkcms.request.v20180308 import QueryMetricListRequest
    from datetime import datetime, timedelta
    import json
    from configparser import ConfigParser
    from utils.const_file import CONFIG_FILE
    
    class 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 CloudMonitorWechat_Info
    from utils.aliyun_monitor import CloudMonitor
    from utils.wechat_send import Wechat_Info
    def 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

    • 注意django-crontab必须在Linux的crontab开启的情况下方可使用,不然会出现不执行的情况;

    参考:https://www.9xkd.com/user/plan-view.html?id=2761461821

    相关文章

      网友评论

        本文标题:Python学习打call第六十七天:将获取的指标封装成接口提供

        本文链接:https://www.haomeiwen.com/subject/xfltgqtx.html