python 監控elasticsearch集群狀態並推送到openfalcon
阿新 • • 發佈：2018-05-31
python 監控elasticsear#!/usr/bin/python
#! --*-- coding:utf-8 --*--
import requests
import time
import json
import sys
import commands
ts = int(time.time())
#print ts
cmd = 'curl 172.31.0.92:9200/_cat/health'
(a, b) = commands.getstatusoutput(cmd)
#print b
status= b.split(' ')[157]
if status=='green':
healthy=3
elif status=='yellow':
healthy=2
elif status=='red':
healthy=1
else:
healthy=0
#print healthy
payload = [
{
"endpoint": "TBK01",
"metric": "elasticsearch_status",
"timestamp": ts,
"step": 60,
"value": 1,
"counterType": "GAUGE",
"tags": "status=green",
}
]
r = requests.post("http://127.0.0.1:1988/v1/push", data=json.dumps(payload))
#print r.text
python 監控elasticsearch集群狀態並推送到openfalcon