#!/usr/bin/env python3.5# -*- coding:utf8 -*-try: import httplibexcept ImportError:  import http.client as httplibimport sys,datetimeimport urllibimport urllib.requestimport urllib.errorimport urllib.parseimport timeimport jsonimport base64import hmac,sslimport uuidfrom hashlib import sha1# 解決 訪問ssl網站證書的問題try:  _create_unverified_https_context = ssl._create_unverified_contextexcept AttributeError:  # Legacy Python that doesn't verify HTTPS certificates by default  passelse:  # Handle target environment that doesn't support HTTPS verification  ssl._create_default_https_context = _create_unverified_https_contextclass 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 instanlistif __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