diff options
author | Morgan Richomme <morgan.richomme@orange.com> | 2016-09-22 15:25:05 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@172.30.200.206> | 2016-09-22 15:25:05 +0000 |
commit | 1b3487ca931821ef762ad103a32118dc99a6fb71 (patch) | |
tree | a517f172a5cc6b353165e0ead0a1a5fceeaa5414 /utils/test/dashboard/kibana_cleanup.py | |
parent | 279e9db83e49f7f7b1358071b3d669f4a810cbb6 (diff) | |
parent | e7b7bb64bf2f3f03980504d80f304e4859146ed2 (diff) |
Merge "rebuild directory structure of Kibana dashboard"
Diffstat (limited to 'utils/test/dashboard/kibana_cleanup.py')
-rw-r--r-- | utils/test/dashboard/kibana_cleanup.py | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/utils/test/dashboard/kibana_cleanup.py b/utils/test/dashboard/kibana_cleanup.py new file mode 100644 index 000000000..9ce4994f5 --- /dev/null +++ b/utils/test/dashboard/kibana_cleanup.py @@ -0,0 +1,41 @@ +#! /usr/bin/env python +import logging +import urlparse + +import argparse + +from dashboard.common import elastic_access + +logger = logging.getLogger('clear_kibana') +logger.setLevel(logging.DEBUG) +file_handler = logging.FileHandler('/var/log/{}.log'.format('clear_kibana')) +file_handler.setFormatter(logging.Formatter('%(asctime)s %(levelname)s: %(message)s')) +logger.addHandler(file_handler) + + +def delete_all(url, es_creds): + ids = elastic_access.get_elastic_docs(url, es_creds, body=None, field='_id') + for id in ids: + del_url = '/'.join([url, id]) + elastic_access.delete_request(del_url, es_creds) + + +if __name__ == '__main__': + parser = argparse.ArgumentParser(description='Delete saved kibana searches, visualizations and dashboards') + parser.add_argument('-e', '--elasticsearch-url', default='http://localhost:9200', + help='the url of elasticsearch, defaults to http://localhost:9200') + + parser.add_argument('-u', '--elasticsearch-username', default=None, + help='The username with password for elasticsearch in format username:password') + + args = parser.parse_args() + base_elastic_url = args.elasticsearch_url + es_creds = args.elasticsearch_username + + urls = (urlparse.urljoin(base_elastic_url, '/.kibana/visualization'), + urlparse.urljoin(base_elastic_url, '/.kibana/dashboard'), + urlparse.urljoin(base_elastic_url, '/.kibana/search')) + + for url in urls: + delete_all(url, es_creds) + |