github
/
ConsulManager
mirror of https://github.com/starsliao/ConsulManager
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Update mysql_huawei.py 

支持大于500指标数
pull/72/head
StarsL.cn 2023-04-13 11:09:12 +08:00 committed by GitHub
parent 20954a5dc3
commit 6b1c8d8851
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
flask-consul/units/prom/mysql_huawei.py
View File

@ -3,6 +3,8 @@ from huaweicloudsdkces.v1.region.ces_region import CesRegion
from huaweicloudsdkces.v1 import * from huaweicloudsdkces.v1 import *
from datetime import datetime from datetime import datetime
from units import consul_kv from units import consul_kv
from units.config_log import *
def exporter(vendor,account,region): def exporter(vendor,account,region):
ak,sk = consul_kv.get_aksk(vendor,account) ak,sk = consul_kv.get_aksk(vendor,account)
credentials = BasicCredentials(ak, sk) credentials = BasicCredentials(ak, sk)
@ -23,21 +25,26 @@ def exporter(vendor,account,region):
for i in metric_name_dict.keys(): for i in metric_name_dict.keys():
for rdsid in rds_list: for rdsid in rds_list:
metric_body_list.append(MetricInfo(namespace="SYS.RDS",metric_name=i,dimensions=[MetricsDimension(name="rds_cluster_id",value=rdsid)])) metric_body_list.append(MetricInfo(namespace="SYS.RDS",metric_name=i,dimensions=[MetricsDimension(name="rds_cluster_id",value=rdsid)]))
request = BatchListMetricDataRequest() request = BatchListMetricDataRequest()
request.body = BatchListMetricDataRequestBody(to=now,_from=now-180000,filter="max",period="1",metrics=metric_body_list) metrics_len = len(metric_body_list)
response = client.batch_list_metric_data(request).to_dict() logger.info(f"metric_body_list长度(实例数*指标数): {metrics_len}")
for i in response['metrics']:
rdsid= i['dimensions'][0]['value'] for i in range(0, metrics_len, 400):
try: sub_metric_list = metric_body_list[i:i+400]
value = i['datapoints'][-1]['max'] request.body = BatchListMetricDataRequestBody(to=now,_from=now-180000,filter="max",period="1",metrics=sub_metric_list)
ts = i['datapoints'][-1]['timestamp'] response = client.batch_list_metric_data(request).to_dict()
except: for i in response['metrics']:
value = -1 rdsid= i['dimensions'][0]['value']
ts = now try:
metric = i['metric_name'] value = i['datapoints'][-1]['max']
prom_metric_name = metric_name_dict[metric][0].split()[2] ts = i['datapoints'][-1]['timestamp']
metric_name_dict[metric].append(f'{prom_metric_name}{{iid="{rdsid}"}} {float(value)} {ts}') except:
value = -1
ts = now
metric = i['metric_name']
prom_metric_name = metric_name_dict[metric][0].split()[2]
metric_name_dict[metric].append(f'{prom_metric_name}{{iid="{rdsid}"}} {float(value)} {ts}')
prom_metric_list = [] prom_metric_list = []
for x in metric_name_dict.values(): for x in metric_name_dict.values():
prom_metric_list = prom_metric_list + x prom_metric_list = prom_metric_list + x