es_clean_bad_indexes.py

import json
import click
import requests


def get_status(node):
    es_stats = requests.get("http://%s:8080/_cluster/health?level=indices" % node)
    indices = es_stats.json()['indices']
    bad_indices = {k:v['status'] for k,v in indices.items() if 'green' not in v['status'] and 'nginx' in k}
    for k,v in bad_indices.items():
        requests.delete('http://%s:8080/%s/' % (node, k))
        print k

@click.command()
@click.option('--node', help='es node to query')
def main(node):
    get_status(node)

if __name__=="__main__":
    main()