FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
netdata/python.d/httpcheck.chart.py at master · absalan/netdata · GitHub
absalan
/
netdata
Public
forked from
netdata/netdata
Notifications
You must be signed in to change notification settings
Fork
0
Star
0
Code
Pull requests
0
Actions
Projects
Wiki
Security and quality
0
Insights
Additional navigation options
Code
Pull requests
Actions
Projects
Wiki
Security and quality
Insights
Expand file tree
Breadcrumbs
netdata
/
python.d
/
httpcheck.chart.py
Copy path
More file actions
More file actions
Latest commit
History
History
History
117 lines (100 loc) · 4.21 KB
Breadcrumbs
netdata
/
python.d
/
httpcheck.chart.py
Copy path
File metadata and controls
117 lines (100 loc) · 4.21 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
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
# -*- coding: utf-8 -*-
# Description: http check netdata python.d module
# Original Author: ccremer (github.com/ccremer)
import
urllib3
import
re
try
:
from
time
import
monotonic
as
time
except
ImportError
:
from
time
import
time
from
bases
.
FrameworkServices
.
UrlService
import
UrlService
# default module values (can be overridden per job in `config`)
update_every
=
3
priority
=
60000
retries
=
60
# Response
HTTP_RESPONSE_TIME
=
'time'
HTTP_RESPONSE_LENGTH
=
'length'
# Status dimensions
HTTP_SUCCESS
=
'success'
HTTP_BAD_CONTENT
=
'bad_content'
HTTP_BAD_STATUS
=
'bad_status'
HTTP_TIMEOUT
=
'timeout'
HTTP_NO_CONNECTION
=
'no_connection'
ORDER
=
[
'response_time'
,
'response_length'
,
'status'
]
CHARTS
=
{
'response_time'
: {
'options'
: [
None
,
'HTTP response time'
,
'ms'
,
'response'
,
'httpcheck.responsetime'
,
'line'
],
'lines'
: [
[
HTTP_RESPONSE_TIME
,
'time'
,
'absolute'
,
100
,
1000
]
]},
'response_length'
: {
'options'
: [
None
,
'HTTP response body length'
,
'characters'
,
'response'
,
'httpcheck.responselength'
,
'line'
],
'lines'
: [
[
HTTP_RESPONSE_LENGTH
,
'length'
,
'absolute'
]
]},
'status'
: {
'options'
: [
None
,
'HTTP status'
,
'boolean'
,
'status'
,
'httpcheck.status'
,
'line'
],
'lines'
: [
[
HTTP_SUCCESS
,
'success'
,
'absolute'
],
[
HTTP_BAD_CONTENT
,
'bad content'
,
'absolute'
],
[
HTTP_BAD_STATUS
,
'bad status'
,
'absolute'
],
[
HTTP_TIMEOUT
,
'timeout'
,
'absolute'
],
[
HTTP_NO_CONNECTION
,
'no connection'
,
'absolute'
]
]}
}
class
Service
(
UrlService
):
def
__init__
(
self
,
configuration
=
None
,
name
=
None
):
UrlService
.
__init__
(
self
,
configuration
=
configuration
,
name
=
name
)
pattern
=
self
.
configuration
.
get
(
'regex'
)
self
.
regex
=
re
.
compile
(
pattern
)
if
pattern
else
None
self
.
status_codes_accepted
=
self
.
configuration
.
get
(
'status_accepted'
, [
200
])
self
.
follow_redirect
=
self
.
configuration
.
get
(
'redirect'
,
True
)
self
.
order
=
ORDER
self
.
definitions
=
CHARTS
def
_get_data
(
self
):
"""
Format data received from http request
:return: dict
"""
data
=
dict
()
data
[
HTTP_SUCCESS
]
=
0
data
[
HTTP_BAD_CONTENT
]
=
0
data
[
HTTP_BAD_STATUS
]
=
0
data
[
HTTP_TIMEOUT
]
=
0
data
[
HTTP_NO_CONNECTION
]
=
0
url
=
self
.
url
try
:
start
=
time
()
status
,
content
=
self
.
_get_raw_data_with_status
(
retries
=
1
if
self
.
follow_redirect
else
False
,
redirect
=
self
.
follow_redirect
)
diff
=
time
()
-
start
data
[
HTTP_RESPONSE_TIME
]
=
max
(
round
(
diff
*
10000
),
0
)
self
.
debug
(
'Url: {url}. Host responded with status code {code} in {diff} s'
.
format
(
url
=
url
,
code
=
status
,
diff
=
diff
))
self
.
process_response
(
content
,
data
,
status
)
except
urllib3
.
exceptions
.
NewConnectionError
as
error
:
self
.
debug
(
"Connection failed: {url}. Error: {error}"
.
format
(
url
=
url
,
error
=
error
))
data
[
HTTP_NO_CONNECTION
]
=
1
except
(
urllib3
.
exceptions
.
TimeoutError
,
urllib3
.
exceptions
.
PoolError
)
as
error
:
self
.
debug
(
"Connection timed out: {url}. Error: {error}"
.
format
(
url
=
url
,
error
=
error
))
data
[
HTTP_TIMEOUT
]
=
1
except
urllib3
.
exceptions
.
HTTPError
as
error
:
self
.
debug
(
"Connection failed: {url}. Error: {error}"
.
format
(
url
=
url
,
error
=
error
))
data
[
HTTP_NO_CONNECTION
]
=
1
except
(
TypeError
,
AttributeError
)
as
error
:
self
.
error
(
'Url: {url}. Error: {error}'
.
format
(
url
=
url
,
error
=
error
))
return
None
return
data
def
process_response
(
self
,
content
,
data
,
status
):
data
[
HTTP_RESPONSE_LENGTH
]
=
len
(
content
)
self
.
debug
(
'Content:
\n
\n
{content}
\n
'
.
format
(
content
=
content
))
if
status
in
self
.
status_codes_accepted
:
if
self
.
regex
and
self
.
regex
.
search
(
content
)
is
None
:
self
.
debug
(
"No match for regex '{regex}' found"
.
format
(
regex
=
self
.
regex
.
pattern
))
data
[
HTTP_BAD_CONTENT
]
=
1
else
:
data
[
HTTP_SUCCESS
]
=
1
else
:
data
[
HTTP_BAD_STATUS
]
=
1
Back
|
FazBrowse Home
|
New Git URL