- 01
- 02
- 03
- 04
- 05
- 06
- 07
- 08
- 09
- 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
#!/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_jvm_threads - A munin plugin that collects stats from the JVM 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 $host = exists $ENV{'host'} ? $ENV{'host'} : 'localhost';
my $port = exists $ENV{'port'} ? $ENV{'port'} : 9200;
my $ua = LWP::UserAgent->new;
$ua->timeout(10);
sub get_json_from_url {
my $uri = shift;
my $res = $ua->get($uri, 'Content-Type' => 'application/json' );
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("http://$host:$port/_nodes/jvm");
my $t_data = get_json_from_url("http://$host:$port/_nodes/stats/jvm");
my %out = (count => 0, peak_count => 0);
foreach my $full_node_name (keys %{$data->{nodes}}) {
next unless $t_data->{nodes}{$full_node_name};
foreach my $name (keys %{ $t_data->{nodes}{$full_node_name}{jvm}{threads} }) {
$out{$name} += $t_data->{nodes}{$full_node_name}{jvm}{threads}{$name};
}
}
if ($ARGV[0] and $ARGV[0] eq 'config') {
print "graph_title Elasticsearch JVM threads\n";
print "graph_category elasticsearch\n";
print "graph_scale no\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);
Комментарии (0) RSS
Добавить комментарий