pip install aliyun-python-sdk-core

pip install aliyun-python-sdk-cms

#!/usr/bin/env python

#coding=utf-8

from aliyunsdkcore import client    #客户类，其实叫account感觉更加合理，因为它是维护accessKeyId和secretKeyId的对象

from aliyunsdkcms.request.v20170301 import QueryMetricListRequest    #QueryMetricList是阿里云方面规定的一个名字，意思是要获取多条监控数据的请求

import json

clt = client.AcsClient('access_key_id','secret_key_id','cn-hangzhou')    
#构建客户对象时需要一明一暗两个KEY，然后第三个参数可以参见“调用方式”那个网页上上面的各个物理区域的代码，比如cn-hangzhou,cn-hongkong,us-west-1等等

request = QueryMetricListRequest.QueryMetricListRequest()
#===========================================================
#下面就是设置request中的各种参数，有可能没有涵盖所有的方法，不过也都大同小异，值得一提的是，可以看到所有参数都是字符串，即便是dimension本来是一个字典，
#period本来是一个数字，两个time本来是时间对象，都要转化成相关的字符串
#===========================================================

request.set_accept_format('JSON')

request.set_Project('acs_slb_dashboard')

request.set_Metric('ActiveConnection')

request.set_StartTime('2017-08-09 11:00:00')

request.set_EndTime('2017-08-09 11:10:00')

request.set_Dimensions(str({'instanceId':'instance_id','port':'port'}))

request.set_Period('')

res = json.loads(clt.do_action_with_exception(request))

#选择with_exception的话出错是以raise Exception的形式报出的，否则就是返回的res是错误码和错误信息这样子。

print json.dumps(res,indent=4)

string_to_sign = ''

    for k, v in sorted(unsign_param.iteritems(), key=lambda x: x[0]):

        string_to_sign += urllib.quote(k) + '=' + urllib.quote(v) + '&'

    string_to_sign = 'GET&%2F&' + urllib.quote(string_to_sign[:-1]).replace('+', '%20').replace('*', '%2A').replace('%7E', '~')

    # 要[:-1]的原因是因为生成string_to_sign的时候，最后必然会多出一个&，这个是不必要的。如果用的是'&'.join(xxx)这样的方法就没有这个烦恼了

    import hashlib,hmac

    coder = hmac.new(key=secret, msg=string_to_sign, digestmod=hashlib.sha1)

    signature = coder.digest().encode('base64').strip()    #记得encode出来行尾有换行符，要去掉

{

    "Code": "200",

    "Success": true,

    "Period": "60",

    "RequestId": "8AE2C5AD-7CB3-4B5D-BE21-72AD4F762D8E",

    "Datapoints": [

        {

            "instanceId": "instance_id",

            "timestamp": 1502263380000,

            "Average": 280,

            "userId": "xxxxxxxxxxxx",

            "Maximum": 280,

            "vip": "x.x.x.x",

            "Minimum": 280,

            "port": "443"

        },

        {

            "instanceId": "instance_id",

            "timestamp": 1502263440000,

            "Average": 2024,

            "userId": "xxxxxxxxxxxx",

            "Maximum": 2024,

            "vip": "x.x.x.x",

            "Minimum": 2024,

            "port": "443"

        }

    ]

}
//数据已做脱敏处理

{

    "Code": "SignatureDoesNotMatch",

    "Message": "Specified signature is not matched with our calculation.",

    "HostId": "metrics.cn-hangzhou.aliyuncs.com",

    "RequestId": "B4086476-2299-45F5-AC99-00AC1769E4D5"

}

#!/usr/bin/env python

# coding=utf-8

# @author:weiyz

import sys

import os

import uuid

import datetime

import urllib

import hmac

try:

    import requests

except ImportError,e:

    import urllib2

try:

    import json

except ImportError,e:

    import simplejson as json

# 配置文件指定

ACCOUNT_CONF_FILE = os.path.join(os.path.abspath(os.path.dirname(__file__)), 'xxxx.ini')

if not os.path.isfile(ACCOUNT_CONF_FILE):

   raise Exception('Configuration file {0} is not found'.format(ACCOUNT_CONF_FILE))

try:

    instance_id = sys.argv[1]

    search_key = sys.argv[2]

    account = sys.argv[3]

    port = sys.argv[4]

    search_type = sys.argv[5]

except IndexError, e:

    raise Exception('Invalid arguments. Check there are four arguments for the script.')

def get_key_from_account():

    '''

    通过读文件获得相关账号的AccessKeyId

    :return:

    '''

    import ConfigParser

    cf = ConfigParser.ConfigParser()

    cf.read(ACCOUNT_CONF_FILE)

    try:

        return cf.get(account, 'id') , cf.get(account,'secret')

    except ConfigParser.NoSectionError:

        raise Exception('Account {0} is not configured in configuration.'.format(account))

def get_sign_param():

    '''

    进行公共参数字典、请求参数字典的汇总，并计算签名，最终把签名也加入字典当中

    最终形成的就是完整的请求参数字典，只要整合成URI就可以发起请求了

    :return:

    '''

    time_format = '%Y-%m-%dT%XZ'

    time_stamp = (datetime.datetime.now() - datetime.timedelta(hours=8)).strftime(time_format)

    access_key_id,secret = get_key_from_account()

    unsign_public_param = {

        'Format': 'JSON',

        'Version': '2017-03-01',

        'AccessKeyId': access_key_id,

        'SignatureMethod': 'HMAC-SHA1',

        'Timestamp': time_stamp,  # 时间戳格式一定是带T和Z的那个

        'SignatureVersion': '1.0',

        'SignatureNonce': str(uuid.uuid1())

    }

    secret += '&'

    req_param = {

        'Action': 'QueryMetricList',

        'Project': 'acs_slb_dashboard',

        'Metric': search_key,

        'Period': '',

        'EndTime': datetime.datetime.now().strftime('%Y-%m-%d %X'),

        'StartTime': (datetime.datetime.now() - datetime.timedelta(minutes=8)).strftime('%Y-%m-%d %X'),

        'Dimensions': str({'instanceId': instance_id, 'port': port})

        # 另外注意Dimensions这个字典里面的key也是要按照顺序排列的

    }

    unsign_param = {}

    unsign_param.update(unsign_public_param)

    del (unsign_public_param)

    unsign_param.update(req_param)

    del (req_param)

    string_to_sign = ''

    for k, v in sorted(unsign_param.iteritems(), key=lambda x: x[0]):

        string_to_sign += urllib.quote(k) + '=' + urllib.quote(v) + '&'

    string_to_sign = 'GET&%2F&' + urllib.quote(string_to_sign[:-1]).replace('+', '%20').replace('*', '%2A').replace('%7E', '~')

    import hashlib

    coder = hmac.new(key=secret, msg=string_to_sign, digestmod=hashlib.sha1)

    signature = coder.digest().encode('base64').strip()

    unsign_param.update({'Signature': signature})

    return unsign_param

if __name__ == '__main__':

    sign_param = get_sign_param()

    base_url = 'http://metrics.cn-hangzhou.aliyuncs.com/'

    if 'requests' in locals():

        res = requests.get(base_url, params=sign_param)

        result = json.loads(res.content)

    elif 'urllib2' in locals():

        req = urllib2.Request(base_url+'?'+urllib.urlencode(sign_param))

        res = urllib2.urlopen(req)

        result = res.read()

        json.loads(result)

    else:

        result = {'Message':'Sending Request Failed.'}

    if result.get('Code') != '' or result.get('Success') != True:

        raise Exception('API Call Failed:[Error Message]{0}'.format(result.get('Message')))

    def filter_result(result):

        for datapoint in result.get('Datapoints'):

            yield datapoint.get('Maximum'), datapoint.get('Average')

    maxlist, avglist = zip(*list(filter_result(result)))

    max_, avg = max(maxlist), max(avglist)

    if search_type == 'max':

        print max_

    elif search_type == 'avg':

        print avg