python3 獲取阿里雲ECS 實例及監控的方法

#!/usr/bin/env python3.5
# -*- coding:utf8 -*-
try: import httplib
except ImportError:
    import http.client as httplib
import sys,datetime
import urllib
import urllib.request
import urllib.error
import urllib.parse
import time
import json
import base64
import hmac,ssl
import uuid
from hashlib import sha1
# 解決 訪問ssl網站證書的問題
try:
    _create_unverified_https_context = ssl._create_unverified_context
except AttributeError:
    # Legacy Python that doesn't verify HTTPS certificates by default
    pass
else:
    # Handle target environment that doesn't support HTTPS verification
    ssl._create_default_https_context = _create_unverified_https_context
class aliyunclient:
    def __init__(self):
        self.access_id = '阿里雲access_id'
        self.access_secret ='阿里雲secret'
        #監控獲取ECS URL
        self.url = 'https://ecs.aliyuncs.com'
    # #簽名
    def sign(self,accessKeySecret, parameters):
        sortedParameters = sorted(parameters.items(), key=lambda parameters: parameters[0])
        canonicalizedQueryString = ''
        for (k,v) in sortedParameters:
            canonicalizedQueryString += '&' + self.percent_encode(k) + '=' + self.percent_encode(v)
        stringToSign = 'GET&%2F&' + self.percent_encode(canonicalizedQueryString[1:])  # 使用get請求方法
        bs = accessKeySecret +'&'
        bs = bytes(bs,encoding='utf8')
        stringToSign = bytes(stringToSign,encoding='utf8')
        h = hmac.new(bs, stringToSign, sha1)
        # 進行編碼
        signature = base64.b64encode(h.digest()).strip()
        return signature
    def percent_encode(self,encodeStr):
        encodeStr = str(encodeStr)
        res = urllib.request.quote(encodeStr)
        res = res.replace('+', '%20')
        res = res.replace('*', '%2A')
        res = res.replace('%7E', '~')
        return res
    # 構建除共公參數外的所有URL
    def make_url(self,params):
        timestamp = time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime())
        parameters = {
            'Format' : 'JSON',
            'Version' : '2014-05-26',
            'AccessKeyId' : self.access_id,
            'SignatureVersion' : '1.0',
            'SignatureMethod' : 'HMAC-SHA1',
            'SignatureNonce' : str(uuid.uuid1()),
            'TimeStamp' : timestamp,
        }
        for key in params.keys():
            parameters[key] = params[key]
        signature = self.sign(self.access_secret,parameters)
        parameters['Signature'] = signature
        url = self.url + "/?" + urllib.parse.urlencode(parameters)
        return url
    def do_action(self,params):
        url = self.make_url(params)
        # print(url)
        request = urllib.request.Request(url)
        try:
            conn = urllib.request.urlopen(request)
            response = conn.read().decode()
        except urllib.error.HTTPError as e:
            print(e.read().strip())
            raise SystemExit(e)
        try:
            res = json.loads(response)
        except ValueError as e:
            raise SystemExit(e)
        return res
# 繼承原始類
class client(aliyunclient):
    def __init__(self,InstanceIds):
        aliyunclient.__init__(self)
        self.InstanceIds = InstanceIds
        # ECS 區域
        self.RegionId = "cn-shanghai"
    # 時間UTC轉換
    def timestrip(self):
        UTCC = datetime.datetime.utcnow()
        utcbefore5 = UTCC - datetime.timedelta(minutes =5)
        Endtime = datetime.datetime.strftime(UTCC, "%Y-%m-%dT%H:%M:%SZ")
        StartTime = datetime.datetime.strftime(utcbefore5, "%Y-%m-%dT%H:%M:%SZ")
        return (StartTime,Endtime)
    def DescribeInstanceMonitorData(self):
        '''
        構造實例監控序列函數
        '''
        self.tt = self.timestrip()
        action_dict ={"StartTime":self.tt[0],"Endtime":self.tt[1],"Action":"DescribeInstanceMonitorData","RegionId":self.RegionId,"InstanceId":self.InstanceId}
        return action_dict
    def DescribeInstances(self):
        '''
        構建實例配置查詢函數
        '''
        action_dict = {"Action":"DescribeInstances","RegionId":self.RegionId,"InstanceIds":self.InstanceIds}
        return action_dict
    def alis_main(self):
        res = self.do_action(self.DescribeInstances())
        listarry = len(res["Instances"]["Instance"])
        a = {}
        cpu = 0
        InternetBandwidth = 0
        instanlist = {"data":a}
        # 調用所有符合條件的實例配置數據
        for i in range(0,listarry):
            self.InstanceId = res["Instances"]["Instance"][i]["InstanceId"]
            BandwidthOUT = res["Instances"]["Instance"][i]["InternetMaxBandwidthOut"]
            # 調用計算該實例的監控數據
            monitordata = self.do_action(self.DescribeInstanceMonitorData())
            data = monitordata["MonitorData"]["InstanceMonitorData"]
            for i in range(0,len(data)):
                cpu += data[i]["CPU"]
                InternetBandwidth += data[i]["InternetBandwidth"]
            # 對該實例數據生成字典
            arry = {"BandwidthOUT":BandwidthOUT,"cpu":cpu/len(data),"InternetBandwidth":InternetBandwidth/len(data)}
            # 將新數據重構到原字典數據
            a.setdefault(self.InstanceId,arry)
        return instanlist
if __name__ == "__main__":
    # 傳實例ID 列表進去
    clt= client(["i-11cy8adf2x"])
    res = clt.alis_main()
    print(res)

# 獲取的結果如下：
{'data': {'i-11cy8adf2x': {'InternetBandwidth': 0.0, 'cpu': 4.0, 'BandwidthOUT': 4}}}
# 解釋 獲取所有實例的 當前配置的帶寬值 當前占用的CPU% 當前占用的出口帶寬 kbps