將獲取的指標(biāo)封裝成接口提供API請(qǐng)求調(diào)用

1.將阿里云的監(jiān)控指標(biāo)推送到企業(yè)微信

• (1)首先需要在項(xiàng)目的根路徑下，創(chuàng)建utils包，用于存放項(xiàng)目的其他數(shù)據(jù)接口；

• (2)然后在utils包下，創(chuàng)建一個(gè) wechat_send.py 模塊, 用于給用戶封裝企業(yè)微信的接口，提供給外界調(diào)用；

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('微信測(cè)試')
    print(result)

• (3)由于 partyID 、 corpID 、 secret 、 agentID 都是配置信息，需要引入一個(gè)讀取配置文件的庫(kù) configparser ；

安裝：
pip install configparser

• (4)為了管理所有的配置文件還需要?jiǎng)?chuàng)建一個(gè)配置文件目錄cfg，可以在cfg目錄下創(chuàng)建配置文件，如 xkd.conf 文件；

[Wechat]
party_id = 1
corp_id = ww5cfabaf35ce8cd7b
secret = uiwvmNj8f1IVy3QYrZ62WePGFKA_BsIPmHigq3TRydM
agent_id = 1000002

• (5)然后可以在utils包下，創(chuàng)建一個(gè) const_file.py 文件，依賴作為項(xiàng)目中全局常量的引用；

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 模塊接口(配置中的信息都是明文的，在項(xiàng)目開(kāi)發(fā)中，最好將重要的配置信息進(jìn)行加密，可以使用base64進(jìn)行加密和解密)；

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('微信測(cè)試')
    print(result)

• (7)在utils包下，創(chuàng)建 aliyun_monitor.py 文件，封裝阿里云的云監(jiān)控?cái)?shù)據(jù)的接口；

• (8)然后編輯xkd.conf配置文件，添加阿里云 RAM access key 和 access key secret 、 region 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是實(shí)例ID
        :param monitor_key: 需要監(jiān)控的指標(biāo)
        :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定時(shí)任務(wù)庫(kù)，需要用到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下創(chuàng)建一個(gè)cron.py文件，導(dǎo)入 import CloudMonitor 和 Wechat_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('當(dāng)前服務(wù)器CPU使用率是：{}'.format(result))

• (13)在settings文件中配置定時(shí)任務(wù)CRONJOBS；

CRONJOBS = [
    ('* * * * *', 'users.cron.send_aliyun_metric_to_wechat')
]

• (14)最后添加定時(shí)任務(wù)： python manage.py crontab add ；

2.configparser模塊

• 安裝命令行： pip install configparser ；

• ConfigParser是用來(lái)讀取配置文件的模塊，配置文件的格式跟windows下的ini配置文件相似，可以包含一個(gè)或多個(gè)section，每個(gè)section都有自己的option；

• section 用 [sect_name] 表示，每個(gè)option是一個(gè)鍵值對(duì)，使用分隔符 = 或 : 隔開(kāi)；

• 在 option 中分隔符兩端的空格會(huì)被忽略掉；

• 配置文件使用可以使用 # 進(jìn)行注釋；

3.django-crontab庫(kù)

安裝命令：
pip install django-crontab

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

• 添加定時(shí)任務(wù)： python manage.py crontab add ，注意如果修改了任務(wù)，也需要再次運(yùn)行此命令；

• 清除定時(shí)任務(wù)： python manage.py crontab remove ；

• 顯示定時(shí)任務(wù)： python manage.py crontab show ；

• 注意 django-crontab 必須在Linux的crontab開(kāi)啟的情況下方可使用，不然會(huì)出現(xiàn)不執(zhí)行的情況；

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