forked from y-ken/munin-plugin-elasticsearch
-
Notifications
You must be signed in to change notification settings - Fork 0
/
elasticsearch_cache
executable file
·91 lines (71 loc) · 2.44 KB
/
elasticsearch_cache
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
#!/usr/bin/env perl
# Parameters supported:
#
# config
# autoconf
#
# Magic markers:
#%# family=auto
#%# capabilities=autoconf
use strict;
use warnings;
use LWP;
use JSON qw/decode_json/;
=head1 NAME
elasticsearch_cache - A munin plugin that collects cache stats of your elasticsearch instances
=head1 APPLICABLE SYSTEMS
Elasticsearch
=head1 CONFIGURATION
None
=head1 BUGS
None known so far. If you find any, let me know.
=head1 AUTHOR
Tomas Doran (t0m) - c<< <[email protected]> >>
Kentaro Yoshida - https://github.com/y-ken
=cut
my $protocol = exists $ENV{'protocol'} ? $ENV{'protocol'} : 'http';
my $host = exists $ENV{'host'} ? $ENV{'host'} : 'localhost';
my $port = exists $ENV{'port'} ? $ENV{'port'} : 9200;
my $user = exists $ENV{'username'} ? $ENV{'username'} : '';
my $pass = exists $ENV{'password'} ? $ENV{'password'} : '';
my $ua = LWP::UserAgent->new;
$ua->timeout(10);
sub get_json_from_url {
my $uri = shift;
my $req = HTTP::Request->new('GET', $uri, ['Content-Type' => 'application/json']);
if ($user ne '') {
$req->authorization_basic($user, $pass);
}
my $res = $ua->request($req);
Carp::confess($res->code . " for " . $uri) unless $res->is_success;
my $data = do { local $@; eval { decode_json($res->content) } };
die("Could not decode JSON from: " . $res->content) unless $data;
return $data;
}
my $data = get_json_from_url("$protocol://$host:$port/_nodes");
my $t_data = get_json_from_url("$protocol://$host:$port/_nodes/stats");
my %out = (field_size => 0, query_size => 0);
foreach my $full_node_name (keys %{$data->{nodes}}) {
next unless $t_data->{nodes}{$full_node_name};
if (defined($t_data->{nodes}{$full_node_name}{indices}{fielddata})) {
$out{field_size} += $t_data->{nodes}{$full_node_name}{indices}{fielddata}{memory_size_in_bytes};
}
if (defined($t_data->{nodes}{$full_node_name}{indices}{query_cache})) {
$out{query_size} += $t_data->{nodes}{$full_node_name}{indices}{query_cache}{memory_size_in_bytes};
}
}
if ($ARGV[0] and $ARGV[0] eq 'config') {
print "graph_args --base 1024\n";
print "graph_title elasticsearch cache\n";
print "graph_category elasticsearch\n";
print "graph_vlabel Bytes\n";
foreach my $name (keys %out) {
print "$name.label $name\n"."$name.type GAUGE\n";
}
}
elsif (!$ARGV[0] || $ARGV[0] eq 'autoconf') {
foreach my $name (keys %out) {
print "$name.value " . $out{$name} . "\n";
}
}
exit(0);