fixshards.php

<?php

$helpopts = array(
    'host:' => 'Host/IP of the Elasticsearch node that runs the REST API',
    'port::' => '(optional) Port for the Elasticsearch node',
    'node:' => 'Node name for the Elasticsearch Indice',
    'pretend' => 'Show sample of the to be dispatched POST Data',
    'help' => 'Shows the available options'
);

$options = getopt('h', array_keys($helpopts));

$showhelp = false;
if (isset($options['h']) || isset($options['help'])) {
    $showhelp = true;
}
if (!isset($options['host']) && !$showhelp) {
    print 'host parameter is missing'.PHP_EOL;
    $showhelp = true;
}
if (!isset($options['node']) && !$showhelp) {
    print 'node parameter is missing'.PHP_EOL;
    $showhelp = true;
}
if ($showhelp) {
    foreach ($helpopts as $option => $help) {
        $option = str_replace('::', '=', $option);
        $option = str_replace(':', '=', $option);
        print sprintf("%-20.20s %-60.60s\n", '--'.$option, $help);
    }
    print sprintf("%-20.20s %-60.60s\n", ' -h', $helpopts['help']);
    exit();
}

$host = $options['host'];
$node = $options['node'];
$port = (isset($options['port'])) ? $options['port'] : '9200';

$json = file_get_contents(sprintf('http://%s:%s/_cluster/state', $host, $port));
$shards = json_decode($json, true);

foreach($shards['routing_table']['indices'] as $indice) {
	foreach($indice['shards'] as $shards) {
	foreach($shards as $shard) {
		if ($shard['state'] == 'UNASSIGNED') {
		$postdata = '{
         "commands" : [ {
               "allocate" : {
                   "index" : "'.$shard['index'].'",
                   "shard" : '.$shard['shard'].',
                   "node" : "'.$node.'",
                   "allow_primary" : true
               }
             }
         ]
     }';
        if (isset($options['pretend'])) {
            echo $postdata.PHP_EOL;
            exit();
        }
		#var_dump($shard);
		$opts = array('http' =>
		    array(
		        'method'  => 'POST',
		        'header'  => 'Content-type: application/json',
		        'content' => $postdata
		    )
		);
		$context  = stream_context_create($opts);
		$result = file_get_contents(sprintf('http://%s:%s/_cluster/reroute', $host, $port), false, $context);
		$response = json_decode($result, true);
		if ($response['acknowledged']) {
			echo 'Shard acknowledged: '.$shard['index'].PHP_EOL;
        } else if ($response['error']) {
            var_dump($response);
            exit();
		} else {
			echo 'Shard denied: '.$shard['index'].PHP_EOL;
		}
		sleep(60);
		}
	}
	}
}