forked from zabbix-tooling/k8s-zabbix
/
check_kubernetesd
executable file
·151 lines (125 loc) · 5.28 KB
/
check_kubernetesd
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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
#!/usr/bin/env python3
""" kubernetes zabbix monitoring daemon
- tries to read config from file (host, port, token)
- sends data to zabbix
- sends data to inventory REST-API
"""
import argparse
import faulthandler
import logging
import os
import signal
import sys
import time
from typing import List
import coloredlogs as coloredlogs
import sentry_sdk
from base.config import Configuration
from base.daemon_thread import CheckKubernetesDaemon
KNOWN_ACTIONS = ["discover", "get"]
formatter_string = '%(asctime)s - %(threadName)s : {%(name)s:%(lineno)d} : %(levelname)s : %(message)s'
logger = logging.getLogger("k8s-zabbix")
if __name__ == '__main__':
parser = argparse.ArgumentParser(
description='Zabbix monitoring daemon for kubernetes'
)
parser.add_argument('--show_effective_config', action='store_true',
help="display the final config as environment variables" +
"based env variables and ini file parameters")
parser.add_argument('--show_ini', action='store_true',
help="show variables as ini files parameters instead of environment variables")
parser.add_argument('--disable_colors', action='store_true', help="disable colors in logoutput")
parser.add_argument('ini_file', nargs="?", type=str,
help="optional, use a additional inifile for configuration " +
"(environment variables take precedence) or execute a " +
"binary with a fully qualified file path")
args = parser.parse_args()
config = Configuration()
if args.ini_file:
if args.ini_file.startswith("/bin/"):
os.system(args.ini_file)
sys.exit(1)
else:
try:
config.load_config_file(args.ini_file)
except Exception as e:
logger.fatal(e)
sys.exit(1)
config.load_from_environment_variables()
if args.show_effective_config:
config.show_effective_config(show_as_ini_variables=args.show_ini)
if config.sentry_enabled:
logger.info("starting with sentry DSN %s" % config.sentry_dsn)
config.sentry_enabled = True
if not config.sentry_dsn:
print("sentry enabled but no DNS set: '%s'! ABORTING!" % config.sentry_dsn)
sentry_sdk.init(config.sentry_dsn)
if config.zabbix_debug:
config.zabbix_debug = True
log = logging.getLogger("pyzabbix")
log.setLevel(logging.DEBUG)
else:
log = logging.getLogger("pyzabbix")
log.setLevel(logging.INFO)
if config.debug:
logger.setLevel(logging.DEBUG)
else:
logger.setLevel(logging.INFO)
coloredlogs.install(level=logging.getLevelName(logger.getEffectiveLevel()),
fmt=formatter_string,
isatty=(not args.disable_colors))
if config.debug:
logger.debug("Starting with DEBUG enabled")
if config.zabbix_debug:
logger.info("starting with zabbix debug")
if config.zabbix_dry_run:
logger.warning("starting with zabbix_dry_run True, not sending to Zabbix!")
daemons: List[CheckKubernetesDaemon] = list()
mgmt_daemon = CheckKubernetesDaemon(config,
['nodes'],
config.discovery_interval_slow, config.resend_data_interval_slow)
daemons.append(mgmt_daemon)
daemons.append(
CheckKubernetesDaemon(config,
['components', 'services', 'pvcs'],
# ['components', 'pvcs'],
config.discovery_interval_slow, config.resend_data_interval_fast))
daemons.append(
CheckKubernetesDaemon(config,
# ['deployments', 'statefulsets', 'daemonsets', 'pods', 'containers',
["statefulsets", "deployments", "daemonsets"],
config.discovery_interval_slow, config.resend_data_interval_slow))
daemons.append(
CheckKubernetesDaemon(config,
# ['deployments', 'statefulsets', 'daemonsets', 'pods', 'containers',
# 'ingresses', 'containers', 'pods'],
["pods", "containers"],
config.discovery_interval_fast, config.resend_data_interval_fast))
if config.debug_k8s_events:
for daemon in daemons:
daemon.debug_k8s_events = True
# SIGNAL processing
def _signal_handler(signum, *args):
mgmt_daemon.handler(signum)
def stacktraces_and_terminate(signum, frame):
print("#" * 80)
print("# Threadump")
faulthandler.dump_traceback()
print("#")
print("#" * 80)
sys.exit(1)
signal.signal(signal.SIGQUIT, stacktraces_and_terminate)
signal.signal(signal.SIGUSR1, _signal_handler)
signal.signal(signal.SIGUSR2, _signal_handler)
# Daemon start
try:
logger.info("Starting daemon threads now")
for daemon in daemons:
daemon.run()
while True:
time.sleep(10)
except KeyboardInterrupt:
logger.info("got SIGINT, shutting down")
for daemon in daemons:
daemon.handler(signal.SIGTERM)
sys.exit(1)