76 lines
2.7 KiB
PHP
76 lines
2.7 KiB
PHP
#!/usr/bin/php
|
|
<?php
|
|
/*
|
|
* Licensed to the Apache Software Foundation (ASF) under one
|
|
* or more contributor license agreements. See the NOTICE file
|
|
* distributed with this work for additional information
|
|
* regarding copyright ownership. The ASF licenses this file
|
|
* to you under the Apache License, Version 2.0 (the
|
|
* "License"); you may not use this file except in compliance
|
|
* with the License. You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
/* This plugin makes call to master node, get the jmx-json document
|
|
* check the corrupt or missing blocks % is > threshod
|
|
* check_hdfs_blocks.php -H hostaddress -p port -w 1% -c 1%
|
|
*/
|
|
|
|
$options = getopt ("h:p:w:c:");
|
|
if (!array_key_exists('h', $options) || !array_key_exists('p', $options) || !array_key_exists('w', $options)
|
|
|| !array_key_exists('c', $options)) {
|
|
usage();
|
|
exit(3);
|
|
}
|
|
|
|
$host=$options['h'];
|
|
$port=$options['p'];
|
|
$warn=$options['w']; $warn = preg_replace('/%$/', '', $warn);
|
|
$crit=$options['c']; $crit = preg_replace('/%$/', '', $crit);
|
|
|
|
/* Get the json document */
|
|
// The following line works on a different version of hdfs, maybe?
|
|
//$json_string = file_get_contents("http://".$host.":".$port."/jmx?qry=Hadoop:service=NameNode,name=FSNamesystemMetrics");
|
|
$json_string = file_get_contents("http://".$host.":".$port."/jmx?qry=Hadoop:service=NameNode,name=FSNamesystem");
|
|
$json_array = json_decode($json_string, true);
|
|
$m_percent = 0;
|
|
$c_percent = 0;
|
|
$object = $json_array['beans'][0];
|
|
$missing_blocks = $object['MissingBlocks'];
|
|
$corrupt_blocks = $object['CorruptBlocks'];
|
|
$total_blocks = $object['BlocksTotal'];
|
|
if($total_blocks == 0) {
|
|
$m_percent = 0;
|
|
$c_percent = 0;
|
|
} else {
|
|
$m_percent = ($missing_blocks/$total_blocks)*100;
|
|
$c_percent = ($corrupt_blocks/$total_blocks)*100;
|
|
}
|
|
$out_msg = "corrupt blocks: " . $corrupt_blocks .
|
|
", missing blocks: " . $missing_blocks .
|
|
", total blocks: " . $total_blocks;
|
|
|
|
if ($m_percent > $crit || $c_percent > $crit) {
|
|
echo "CRITICAL: " . $out_msg . "\n";
|
|
exit (2);
|
|
}
|
|
if ($m_percent > $warn || $c_percent > $warn) {
|
|
echo "WARNING: " . $out_msg . "\n";
|
|
exit (1);
|
|
}
|
|
echo "OK: " . $out_msg . "\n";
|
|
exit(0);
|
|
|
|
/* print usage */
|
|
function usage () {
|
|
echo "Usage: $0 -h <host> -p port -w <warn%> -c <crit%>\n";
|
|
}
|
|
?>
|