zabbix 监控 ElasticSearch

Posted 2020-09-25 三木燕

ElasticSearch  可以直接使用zabbix官方的模板

模板地址：

https://github.com/mkhpalm/elastizabbix

 

通过zabbix server 直接监控

1、下载模板文件导入模板

2、把模板关联到zabbix server

3、添加自定义KEY

 

vim /etc/zabbix/scripts/elastizabbix.py

#!/usr/bin/python
import os
import sys
import json
import urllib2
import time
import errno


ttl = 60



stats = {
    \'cluster\': \'http://localhost:9200/_cluster/stats\',
    \'nodes\'  : \'http://localhost:9200/_nodes/stats\',
    \'indices\': \'http://localhost:9200/_stats\',
    \'health\' : \'http://localhost:9200/_cluster/health\'
}



def created_file(name):
    try:
        fd = os.open(name, os.O_WRONLY | os.O_CREAT | os.O_EXCL)
        os.close(fd)
        return True
    except OSError, e:
        if e.errno == errno.EEXIST:
            return False
        raise



def is_older_then(name, ttl):
    age = time.time() - os.path.getmtime(name)
    return age > ttl



def get_cache(api):
    cache = \'/tmp/elastizabbix-{0}.json\'.format(api)
    lock = \'/tmp/elastizabbix-{0}.lock\'.format(api)
    should_update = (not os.path.exists(cache)) or is_older_then(cache, ttl)
    if should_update and created_file(lock):
        try:
            d = urllib2.urlopen(stats[api]).read()
            with open(cache, \'w\') as f: f.write(d)
        except Exception as e:
            pass        
        if os.path.exists(lock):
            os.remove(lock)
    if  os.path.exists(lock) and is_older_then(lock, 300):
        os.remove(lock)
    ret_data = {}
    try:
        with open(cache)  as data_file:    
            ret_data = json.load(data_file)        
    except Exception as e:
        ret_data = json.loads(urllib2.urlopen(stats[api]).read())
    return ret_data   



def get_stat(api, stat):
    d = get_cache(api)
    keys = []
    for i in stat.split(\'.\'):
        keys.append(i)
        key = \'.\'.join(keys)
        if key in d:
            d = d.get(key)
            keys = []
    return d



def discover_nodes():
    d = {\'data\': []}
    for k,v in get_stat(\'nodes\', \'nodes\').iteritems():
        d[\'data\'].append({\'{#NAME}\': v[\'name\'], \'{#NODE}\': k})
    return json.dumps(d)



def discover_indices():
    d = {\'data\': []}
    for k,v in get_stat(\'indices\', \'indices\').iteritems():
        d[\'data\'].append({\'{#NAME}\': k})
    return json.dumps(d)




if __name__ == \'__main__\':
    api = sys.argv[1]
    stat = sys.argv[2]
    if api == \'discover\':
        if stat == \'nodes\':
            print discover_nodes()
        if stat == \'indices\':
            print discover_indices()



    else:
        stat = get_stat(api, stat)
        if isinstance(stat, dict):
            print \'\'
        else:
            print stat

 

 

vim /etc/zabbix/zabbix_agentd.d/es.conf

UserParameter=elastizabbix[*],/etc/zabbix/scripts/elastizabbix.py $1 $2