將獲取的指標(biāo)封裝成接口提供API請(qǐng)求調(diào)用-創(chuàng)新互聯(lián)
1.將阿里云的監(jiān)控指標(biāo)推送到企業(yè)微信
(1)首先需要在項(xiàng)目的根路徑下，創(chuàng)建utils包，用于存放項(xiàng)目的其他數(shù)據(jù)接口；
在安仁等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供成都網(wǎng)站制作、網(wǎng)站設(shè)計(jì) 網(wǎng)站設(shè)計(jì)制作按需規(guī)劃網(wǎng)站,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),成都品牌網(wǎng)站建設(shè),成都營銷網(wǎng)站建設(shè),成都外貿(mào)網(wǎng)站建設(shè)公司,安仁網(wǎng)站建設(shè)費(fèi)用合理。
(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 = "/tupian/20230522/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 = "/tupian/20230522/send
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è)讀取配置文件的庫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)目開發(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 = "/tupian/20230522/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 = "/tupian/20230522/send
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ù)庫，需要用到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是用來讀取配置文件的模塊，配置文件的格式跟windows下的ini配置文件相似，可以包含一個(gè)或多個(gè)section，每個(gè)section都有自己的option；
section 用 [sect_name] 表示，每個(gè)option是一個(gè)鍵值對(duì)，使用分隔符
=或:隔開；在 option 中分隔符兩端的空格會(huì)被忽略掉；
配置文件使用可以使用
#進(jìn)行注釋；
3.django-crontab庫
安裝命令：
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開啟的情況下方可使用，不然會(huì)出現(xiàn)不執(zhí)行的情況；
參考： /tupian/20230522/login.html
新聞標(biāo)題：將獲取的指標(biāo)封裝成接口提供API請(qǐng)求調(diào)用-創(chuàng)新互聯(lián)
本文鏈接：http://muchs.cn/article16/dhojgg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信公眾號(hào)、建站公司、App開發(fā)、商城網(wǎng)站、用戶體驗(yàn)、網(wǎng)站設(shè)計(jì)公司
聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容
- Nacosdocker實(shí)現(xiàn)單機(jī)模式部署-創(chuàng)新互聯(lián)
- 怎么配置Java的工作環(huán)境-創(chuàng)新互聯(lián)
- 常見的局域網(wǎng)拓?fù)浣Y(jié)構(gòu)可以劃分為什么類型-創(chuàng)新互聯(lián)
- python中怎么獲取apk的packagename和activity-創(chuàng)新互聯(lián)
- MongoDB聚合分組取第一條記錄的案例與實(shí)現(xiàn)方法-創(chuàng)新互聯(lián)
- 產(chǎn)品設(shè)計(jì)對(duì)用戶運(yùn)營有什么影響-創(chuàng)新互聯(lián)
- 如何用CSS定義的PNG透明效果兼容各瀏覽器-創(chuàng)新互聯(lián)
- 深圳商城網(wǎng)站制作小技巧 2021-11-15
- 如何優(yōu)化商城網(wǎng)站方法有哪些 2022-11-25
- 三級(jí)分銷微信小程序商城如何定制？ 2013-12-29
- 服裝商城網(wǎng)站建設(shè)定制開發(fā) 2016-11-14
- 成都商城網(wǎng)站建設(shè)都有哪些功能？ 2016-09-19
- 服裝類商城網(wǎng)站 2023-02-09
- 商城網(wǎng)站推廣方法匯總 如何把商城網(wǎng)站快速的推廣出去 2022-08-01
- 那曲網(wǎng)站建設(shè)：手機(jī)商城網(wǎng)站首頁制作技巧 2021-12-10
- 微商城系統(tǒng)開發(fā)需要具備哪些前提條件 2016-10-17
- 商城網(wǎng)站制作費(fèi)用與哪些方面有關(guān)系 2016-11-13
- 如何做好商城網(wǎng)站建設(shè)？ 2022-09-30
- 商城網(wǎng)站做優(yōu)化的具體細(xì)節(jié)，網(wǎng)站SEO的具體細(xì)節(jié) 2022-06-12