diff options
author | SerenaFeng <feng.xiaowei@zte.com.cn> | 2016-09-22 16:15:58 +0800 |
---|---|---|
committer | SerenaFeng <feng.xiaowei@zte.com.cn> | 2016-09-22 16:15:58 +0800 |
commit | e7b7bb64bf2f3f03980504d80f304e4859146ed2 (patch) | |
tree | b51669d1a1932e4397ee366c67f66c6ffad4593e /utils/test/dashboard/kibana_cleanup.py | |
parent | 9f7616b1e09a5d1aa2828f91c2b6f0e534e7a85f (diff) |
rebuild directory structure of Kibana dashboard
JIRA: FUNCTEST-465
Change-Id: Icecd350b2f67105c8aaa9d71fd76d24827515545
Signed-off-by: SerenaFeng <feng.xiaowei@zte.com.cn>
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) + |