prometheus http api 获取数据 参考官方地址
1、curl方式
curl http://192.168.211.21:9990/api/v1/query?query=kafka_topic_partition_current_offset
curl http://192.168.211.21:9990/api/v1/query -XPOST --header "Content-Type:application/x-www-form-urlencoded" -d 'query=kafka_topic_partition_current_offset{instance="192.168.211.21:9308"}'
2、python方式
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import requests
import sys
if len(sys.argv) != 4:
quit('\n\
脚本需要3个参数；example: python3 status-prometheus.py 10.76.211.21 logs 1\n \
第1个参数：哪个kafka集群ip)\n \
第2个参数：需要统计的kafka topic名称\n \
第3个参数：统计当前时间前几天的数据\n'
)
ip = sys.argv[1]
topic = sys.argv[2]
days = sys.argv[3]
url = 'http://192.168.211.21:9990/api/v1/query'
headers = {
'Content-Type':'application/x-www-form-urlencoded'
}
expr = 'sum(kafka_topic_partition_current_offset{instance="%s:9308",topic="%s"} - kafka_topic_partition_current_offset{instance="%s:9308",topic="%s"} offset %sd)' % (ip, topic, ip, topic, days)
#print(expr)
data = {
'query': expr
}
r = requests.post(url=url, data=data, headers=headers)
#print(r.status_code)
#print(r.text)
res = r.json()
for da in res.get('data').get('result'):
values = da.get('value')
print(int(values[1]))
