1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
# -*- coding: utf-8 -*-
# Description: redis netdata python.d module
# Author: Pawel Krupa (paulfantom)
from base import SocketService
# default module values (can be overridden per job in `config`)
#update_every = 2
priority = 60000
retries = 5
# default job configuration (overridden by python.d.plugin)
# config = {'local': {
# 'update_every': update_every,
# 'retries': retries,
# 'priority': priority,
# 'host': 'localhost',
# 'port': 6379,
# 'unix_socket': None
# }}
ORDER = ['operations', 'hit_rate', 'memory', 'keys', 'clients', 'slaves']
CHARTS = {
'operations': {
'options': [None, 'Operations', 'operations/s', 'Statistics', 'redis.statistics', 'line'],
'lines': [
['instantaneous_ops_per_sec', 'operations', 'absolute']
]},
'hit_rate': {
'options': [None, 'Hit rate', 'percent', 'Statistics', 'redis.statistics', 'line'],
'lines': [
['hit_rate', 'rate', 'absolute']
]},
'memory': {
'options': [None, 'Memory utilization', 'kilobytes', 'Memory', 'redis.memory', 'line'],
'lines': [
['used_memory', 'total', 'absolute', 1, 1024],
['used_memory_lua', 'lua', 'absolute', 1, 1024]
]},
'keys': {
'options': [None, 'Database keys', 'keys', 'Keys', 'redis.keys', 'line'],
'lines': [
# lines are created dynamically in `check()` method
]},
'clients': {
'options': [None, 'Clients', 'clients', 'Clients', 'redis.clients', 'line'],
'lines': [
['connected_clients', 'connected', 'absolute'],
['blocked_clients', 'blocked', 'absolute']
]},
'slaves': {
'options': [None, 'Slaves', 'slaves', 'Replication', 'redis.replication', 'line'],
'lines': [
['connected_slaves', 'connected', 'absolute']
]}
}
class Service(SocketService):
def __init__(self, configuration=None, name=None):
SocketService.__init__(self, configuration=configuration, name=name)
self.request = "INFO\r\n"
self.host = "localhost"
self.port = 6379
self.unix_socket = None
self.order = ORDER
self.definitions = CHARTS
def _get_data(self):
"""
Get data from socket
:return: dict
"""
try:
raw = self._get_raw_data().split("\n")
except AttributeError:
return None
data = {}
for line in raw:
if line.startswith(('instantaneous', 'keyspace', 'used_memory', 'connected', 'blocked')):
try:
t = line.split(':')
data[t[0]] = int(t[1])
except (IndexError, ValueError):
pass
elif line.startswith('db'):
tmp = line.split(',')[0].replace('keys=', '')
record = tmp.split(':')
data[record[0]] = int(record[1])
try:
data['hit_rate'] = int((data['keyspace_hits'] / float(data['keyspace_hits'] + data['keyspace_misses'])) * 100)
except:
data['hit_rate'] = 0
return data
def check(self):
"""
Parse configuration, check if redis is available, and dynamically create chart lines data
:return: boolean
"""
self._parse_config()
if self.name == "":
self.name = "local"
self.chart_name += "_" + self.name
data = self._get_data()
if data is None:
self.error("No data received")
return False
for name in data:
if name.startswith('db'):
self.definitions['keys']['lines'].append([name.decode(), None, 'absolute'])
return True
|
