1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
#!/usr/bin/env python
###
# ============LICENSE_START=======================================================
# ONAP CLAMP
# ================================================================================
# Copyright (C) 2018 AT&T Intellectual Property. All rights
# reserved.
# ================================================================================
# Licensed 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.
# ============LICENSE_END============================================
# ===================================================================
#
###
import json
import logging
import os
import sys
import requests
PER_PAGE = 1000
def parse_args(args):
""" Parse arguments given to this script"""
import argparse
parser = argparse.ArgumentParser(
description=('Description of the script'))
parser.add_argument('-v', '--verbose', dest='log_level', action='store_const',
const=logging.DEBUG, default=logging.INFO,
help='Use verbose logging')
parser.add_argument('-C', '--configuration_path',
default='./default',
help='Path of the configuration to be backed up.')
parser.add_argument('-f', '--force', action='store_const',
const=True, default=False,
help=('If the save folder already exists, overwrite files'
' matching a configuration item that should be written.'
' Files already in the folder that do not match are'
' left as-is.'))
parser.add_argument('-H', '--kibana-host', default='https://localhost:5601',
help='Kibana endpoint.')
return parser.parse_args(args)
def get_logger(args):
"""Creates the logger based on the provided arguments"""
logging.basicConfig()
logger = logging.getLogger(__name__)
logger.setLevel(args.log_level)
return logger
def main():
""" This script dumps the kibana configuration from Kibana"""
args = parse_args(sys.argv[1:])
base_config_path = args.configuration_path
# get list of the set of objects we update
url = "%s/api/saved_objects/_find" % (args.kibana_host.rstrip("/"),)
saved_objects_req = requests.get(url, auth=('admin', 'admin'), verify=False,
params={'per_page': PER_PAGE,'type':['config','search','dashboard','visualization','index-pattern']})
saved_objects = saved_objects_req.json()['saved_objects']
for obj in saved_objects:
obj_folder = os.path.sep.join((base_config_path, obj['type']))
if not os.path.exists(obj_folder):
os.makedirs(obj_folder)
filename = "%s/%s-%s.json" % (obj_folder, obj['type'], obj['id'])
with open(filename, 'w') as file:
json.dump(obj, fp=file)
if __name__ == "__main__":
main()
|
