Zabbix uses Python to monitor Alibaba Cloud ECS

1. Install the required modules first

# pip install aliyunsdkcore
# pip install aliyunsdkecs
# pip install aliyunsdkcms

2. Obtain an SLB instance for automatic discovery on Zabbix

#!/bin/python
#coding=utf-8
# Get detailed information of all ecs instances
# discovery_ecs.py

from aliyunsdkcore import client
from aliyunsdkecs.request.v20140526 import DescribeInstancesRequest
import json

Id = 'xxx'
Secret = 'xxx'
RegionId = 'cn-shenzhen'

clt = client.AcsClient(Id,Secret,RegionId)
request = DescribeInstancesRequest.DescribeInstancesRequest();
request.set_accept_format('json')
response = json.loads(clt.do_action_with_exception(request), encoding='utf-8')
# print(response)
InstanceIdList = []
InstanceIdDict = {}
ZabbixDataDict = {}
for i in response['Instances']['Instance']:
InstanceIdDict['{#INSTANCEID}'] = i['InstanceId']
InstanceIdList.append(InstanceIdDict)
ZabbixDataDict["data"] = InstanceIdList
print(ZabbixDataDict)

3. Collect various monitoring indicator data on the SLB instance

#!/bin/python
#coding=utf-8
#check_ecs.py
# ecs monitoring indicator information

import json
import sys
import time
import datetime
from aliyunsdkcore import client
from aliyunsdkcms.request.v20180308 import QueryMetricListRequest # query for a period of time
from aliyunsdkcms.request.v20180308 import QueryMetricLastRequest # Query the latest record


Id = 'xxx'
Secret = 'xxx'
RegionId = 'cn-shenzhen'

clt = client.AcsClient(Id,Secret,RegionId)

def getMetricData(instanceId, metric):
request = QueryMetricLastRequest.QueryMetricLastRequest()
request.set_accept_format('json')
request.set_Project('acs_ecs_dashboard')
request.set_Metric(metric)
request.set_Dimensions("{'instanceId':'%s'}" % instanceId)
request. set_Period('60')
response = clt.do_action_with_exception(request)
return json. loads(response)

instanceId = sys.argv[1]
metric = sys.argv[2]

if metric == "CPUUtilization":
CPUUtilization = getMetricData(instanceId,"CPUUtilization")
print(CPUUtilization)
elif metric == "DiskReadIOPS": # system disk read IOPS
DiskReadIOPS = getMetricData(instanceId,"DiskReadIOPS")
elif metric == "DiskWriteIOPS": # system disk write IOPS
DiskReadIOPS = getMetricData(instanceId,"DiskWriteIOPS")
elif metric == "cpu_idle": # Current idle CPU percentage
DiskReadIOPS = getMetriceData(instanceId,"cpu_idle")