-
Notifications
You must be signed in to change notification settings - Fork 34
/
server_mgr_main.py
executable file
·4875 lines (4527 loc) · 222 KB
/
server_mgr_main.py
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
#!/usr/bin/env python
# vim: tabstop=4 shiftwidth=4 softtabstop=4
"""
Name : server_manager.py
Author : Abhay Joshi
Description : This file contains code that provides REST api interface to
configure, get and manage configurations for servers which
are part of the contrail cluster of nodes, interacting
together to provide a scalable virtual network system.
"""
import os
import glob
import sys
import re
import datetime
import json
import argparse
from gevent import monkey
monkey.patch_all(thread=not 'unittest' in sys.modules)
import subprocess
import bottle
from bottle import route, run, request, abort
import ConfigParser
import paramiko
import base64
import shutil
import string
import tarfile
from urlparse import urlparse, parse_qs
from time import gmtime, strftime, localtime
import pdb
import server_mgr_db
import ast
import uuid
import traceback
import platform
from netaddr import *
import copy
import distutils.core
from server_mgr_defaults import *
from server_mgr_err import *
from server_mgr_status import *
from server_mgr_db import ServerMgrDb as db
from server_mgr_certs import ServerMgrCerts
from server_mgr_utils import *
try:
from server_mgr_cobbler import ServerMgrCobbler as ServerMgrCobbler
except ImportError:
pass
try:
from server_mgr_mon_base_plugin import ServerMgrMonBasePlugin
except ImportError:
pass
from server_mgr_puppet import ServerMgrPuppet as ServerMgrPuppet
from server_mgr_logger import ServerMgrlogger as ServerMgrlogger
from server_mgr_logger import ServerMgrTransactionlogger as ServerMgrTlog
from server_mgr_exception import ServerMgrException as ServerMgrException
from server_mgr_validations import ServerMgrValidations as ServerMgrValidations
import pycurl
import json
import xmltodict
from StringIO import StringIO
import requests
import tempfile
from contrail_defaults import *
from gevent import monkey
monkey.patch_all()
import gevent
from gevent.queue import Queue
bottle.BaseRequest.MEMFILE_MAX = 2 * 102400
_WEB_HOST = '127.0.0.1'
_WEB_PORT = 9001
_DEF_CFG_DB = 'cluster_server_mgr.db'
_DEF_SMGR_BASE_DIR = '/etc/contrail_smgr/'
_DEF_SMGR_CFG_FILE = _DEF_SMGR_BASE_DIR + 'sm-config.ini'
_SERVER_TAGS_FILE = 'tags.ini'
_DEF_HTML_ROOT_DIR = '/var/www/html/'
_DEF_COBBLER = 'True'
_DEF_MONITORING = 'True'
_DEF_COBBLER_IP = '127.0.0.1'
_DEF_COBBLER_PORT = None
_DEF_COBBLER_USERNAME = 'cobbler'
_DEF_COBBLER_PASSWORD = 'cobbler'
_DEF_IPMI_USERNAME = 'ADMIN'
_DEF_IPMI_PASSWORD = 'ADMIN'
_DEF_IPMI_TYPE = 'ipmilan'
_DEF_PUPPET_DIR = '/etc/puppet/'
_DEF_COLLECTORS_IP = "['127.0.0.1:8086']"
_DEF_INTROSPECT_PORT = 8107
_DEF_SANDESH_LOG_LEVEL = 'SYS_INFO'
_DEF_ROLE_SEQUENCE_DEF_FILE = _DEF_SMGR_BASE_DIR + 'role_sequence.json'
_CONTRAIL_CENTOS_REPO = 'contrail-centos-repo'
_CONTRAIL_REDHAT_REPO = 'contrail-redhat-repo'
_DEF_SMGR_PROVISION_LOGS_DIR = '/var/log/contrail-server-manager/provision/'
# Temporary variable added to disable use of new puppet framework. This should be removed/enabled
# only after the new puppet framework has been fully tested. Value is set to TRUE for now, remove
# this variable and it's use when enabling new puppet framework.
_ENABLE_NEW_PUPPET_FRAMEWORK = True
@bottle.error(403)
def error_403(err):
return err.body
# end error_403
@bottle.error(404)
def error_404(err):
return err.body
# end error_404
@bottle.error(409)
def error_409(err):
return err.body
# end error_409
@bottle.error(500)
def error_500(err):
return err.body
# end error_500
@bottle.error(503)
def error_503(err):
return err.body
# end error_503
class VncServerManager():
'''
This is the main class that makes use of bottle package to provide rest
interface for the server manager. This class serves rest APIs and then
processes cluster, server and nodes classes in accordance with information
provided in the REST calls.
'''
_smgr_log = None
_smgr_trans_log = None
_tags_list = ['tag1', 'tag2', 'tag3', 'tag4',
'tag5', 'tag6', 'tag7']
_image_list = ["centos", "fedora", "ubuntu", "redhat",
"contrail-ubuntu-package", "contrail-centos-package",
"contrail-storage-ubuntu-package",
"esxi5.5", "esxi5.1"]
_iso_types = ["centos", "redhat", "ubuntu", "fedora", "esxi5.1", "esxi5.5"]
_package_types = ["contrail-ubuntu-package", "contrail-centos-package",
"contrail-storage-ubuntu-package"]
_image_category_list = ["image", "package"]
_control_roles = ['database', 'openstack', 'config', 'control', 'collector', 'webui']
_role_sequence = [(['haproxy'], 'p'),
(['database'], 'p'), (['openstack'], 'p'),
(['config'], 'p'), (['control'], 'p'),
(['collector'], 'p'), (['webui'], 'p')]
_role_step_sequence_ha = [(['keepalived'], 'p'), (['haproxy'], 'p'),
(['database'], 'p'), (['openstack'], 'p'),
(['pre_exec_vnc_galera'], 's'),
(['post_exec_vnc_galera'], 's'),
(['config'], 'p'), (['control'], 'p'),
(['collector'], 'p'), (['webui'], 'p')]
_role_step_sequence_contrail_ha = [(['keepalived'], 'p'), (['haproxy'], 'p'),
(['database'], 'p'), (['openstack'], 'p'),
(['config'], 'p'), (['control'], 'p'),
(['collector'], 'p'), (['webui'], 'p')]
#_role_sequence = [(['database', 'openstack', 'config', 'control', 'collector', 'webui'], 'p')]
#_role_sequence = [(['database', 'openstack', 'config', 'control', 'collector', 'webui'], 's')]
_compute_roles = ['compute', 'tsn', 'toragent','storage-compute', 'storage-master']
_roles = _control_roles + _compute_roles
_control_step_roles = ['database', 'openstack', 'config', 'control', 'collector', 'webui']
_compute_step_roles = ['compute', 'tsn', 'toragent','storage-compute', 'storage-master']
_openstack_steps = ['pre_exec_vnc_galera', 'post_exec_vnc_galera', 'keepalived', 'haproxy']
_role_steps = _control_roles + _openstack_steps + _compute_roles
_control_step_roles = ['database', 'openstack', 'config', 'control', 'collector', 'webui']
_compute_step_roles = ['compute', 'storage-compute', 'storage-master']
_step_roles = _control_step_roles + _compute_step_roles
_tags_dict = {}
_rev_tags_dict = {}
_monitoring_base_plugin_obj = None
_monitoring_config_set = False
_inventory_config_set = False
_monitoring_gevent_thread_obj = None
# dict to hold cfg defaults
_cfg_defaults_dict = {}
#dict to hold code defaults
_code_defaults_dict = {}
_smgr_config = None
#fileds here except match_keys, obj_name and primary_key should
#match with the db columns
def _is_cobbler_enabled(self, cobbler):
if cobbler.lower() == 'true':
return True
else:
return False
def _is_monitoring_enabled(self, monitoring):
if monitoring.lower() == 'true':
return True
else:
return False
def _do_puppet_kick(self, host_ip):
msg = "Puppet kick trigered for %s" % (host_ip)
self._smgr_log.log(self._smgr_log.INFO, msg)
try:
rc = subprocess.check_call(
["puppet", "kick", "--host", host_ip])
# Log, return error if return code is non-null - TBD Abhay
except subprocess.CalledProcessError as e:
msg = ("put_image: error %d when executing"
"\"%s\"" %(e.returncode, e.cmd))
self._smgr_log.log(self._smgr_log.ERROR, msg)
def merge_dict(self, d1, d2):
for k,v2 in d2.items():
v1 = d1.get(k) # returns None if v1 has no value for this key
if ( isinstance(v1, dict) and
isinstance(v2, dict) ):
self.merge_dict(v1, v2)
elif v1:
#do nothing, Retain value
msg = "%s already present in dict d1," \
"Retaining value %s against %s" % (k, v1, v2)
self._smgr_log.log(self._smgr_log.INFO, msg)
else:
#do nothing, Retain value
msg = "adding %s:%s" % (k, v1)
self._smgr_log.log(self._smgr_log.INFO, msg)
d1[k] = copy.deepcopy(v2)
def _cfg_parse_defaults(self, cfg_def_objs):
defaults_dict = {}
cur_dict = defaults_dict
for k,v in cfg_def_objs.items():
d_dict = v
cur_dict = defaults_dict
if k in cur_dict:
cur_dict_l1 = cur_dict[k]
continue
else:
new_dict = {}
cur_dict[k] = new_dict
previous_dict_l1 = cur_dict
cur_dict_l1 = new_dict
for k,v in d_dict.items():
cur_dict = cur_dict_l1
dict_key_list = k.split(".")
for x in dict_key_list:
if x in cur_dict:
cur_dict = cur_dict[x]
continue
else:
new_dict = {}
cur_dict[x] = new_dict
previous_dict = cur_dict
cur_dict = new_dict
previous_dict[x] = v
return defaults_dict
def _prepare_code_defaults(self):
code_defaults_dict = {}
obj_list = {"server" : server_fields, "cluster": cluster_fields,
"image": image_fields}
for obj_name, obj in obj_list.items():
obj_cpy = obj.copy()
pop_items = ["match_keys", "obj_name", "primary_keys"]
obj_cpy.pop("match_keys")
obj_cpy.pop("obj_name")
obj_cpy.pop("primary_keys")
parameters = eval(obj_cpy.get("parameters", {}))
obj_cpy["parameters"] = parameters
code_defaults_dict[obj_name] = obj_cpy
return code_defaults_dict
def __init__(self, args_str=None):
self._args = None
#Create an instance of logger
try:
self._smgr_log = ServerMgrlogger()
except:
print "Error Creating logger object"
self._smgr_log.log(self._smgr_log.INFO, "Starting Server Manager")
#Create an instance of Transaction logger
try:
self._smgr_trans_log = ServerMgrTlog()
except:
print "Error Creating Transaction logger object"
try:
self._smgr_validations = ServerMgrValidations()
except:
print "Error Creating ServerMgrValidations object"
if not args_str:
args_str = sys.argv[1:]
self._parse_args(args_str)
self._cfg_obj_defaults = self._read_smgr_object_defaults(self._smgr_config)
self._cfg_defaults_dict = self._cfg_parse_defaults(self._cfg_obj_defaults)
self._code_defaults_dict = self._prepare_code_defaults()
# Reads the tags.ini file to get tags mapping (if it exists)
if os.path.isfile(self._args.server_manager_base_dir + _SERVER_TAGS_FILE):
tags_config = ConfigParser.SafeConfigParser()
tags_config.read(self._args.server_manager_base_dir + _SERVER_TAGS_FILE)
tags_config_dict = dict(tags_config.items("TAGS"))
for key, value in tags_config_dict.iteritems():
if key not in self._tags_list:
self._smgr_log.log(
self._smgr_log.ERROR,
"Invalid tag %s in tags ini file"
%(key))
exit()
if value:
self._tags_dict[key] = value
self._rev_tags_dict[value] = key
# end if os.path.isfile()
# Connect to the cluster-servers database
try:
self._serverDb = db(
self._args.server_manager_base_dir+self._args.database_name)
except:
self._smgr_log.log(self._smgr_log.ERROR,
"Error Connecting to Server Database %s"
% (self._args.server_manager_base_dir+self._args.database_name))
exit()
# Add server tags to the DB
try:
self._serverDb.add_server_tags(self._tags_dict)
except:
self._smgr_log.log(
self._smgr_log.ERROR,
"Error adding server tags to server manager DB")
exit()
# Create an instance of cobbler interface class and connect to it.
try:
self._smgr_cobbler = None
if self._is_cobbler_enabled(self._args.cobbler):
self._smgr_cobbler = ServerMgrCobbler(self._args.server_manager_base_dir,
self._args.cobbler_ip_address,
self._args.cobbler_port,
self._args.cobbler_username,
self._args.cobbler_password)
# Copy contrail centos/redhat repo to cobber repos, so that target
# systems can install and run puppet agent from kickstart.
if self._smgr_cobbler:
self._smgr_cobbler._init_create_repo(
_CONTRAIL_CENTOS_REPO, self._args.server_manager_base_dir)
self._smgr_cobbler._init_create_repo(
_CONTRAIL_REDHAT_REPO, self._args.server_manager_base_dir)
except:
print "Error connecting to cobbler"
exit()
# Create an instance of puppet interface class.
try:
# TBD - Puppet parameters to be added.
self._smgr_puppet = ServerMgrPuppet(self._args.server_manager_base_dir,
self._args.puppet_dir)
except:
self._smgr_log.log(self._smgr_log.ERROR, "Error creating instance of puppet object")
exit()
# Start gevent thread for reimage task.
self._reimage_queue = Queue()
gevent.spawn(self._reimage_server_cobbler)
try:
# needed for testing...
status_thread_config = {}
status_thread_config['listen_ip'] = self._args.listen_ip_addr
status_thread_config['listen_port'] = '9002'
status_thread_config['base_obj'] = self._monitoring_base_plugin_obj
status_thread_config['smgr_puppet'] = self._smgr_puppet
status_thread_config['smgr_main'] = self
status_thread = ServerMgrStatusThread(
None, "Status-Thread", status_thread_config)
# Make the thread as daemon
status_thread.daemon = True
status_thread.start()
except:
self._smgr_log.log(self._smgr_log.ERROR,
"Error starting the status thread")
exit()
# Generate SM Certs
self._smgr_certs = ServerMgrCerts()
sm_private_key, sm_cert = self._smgr_certs.create_sm_ca_cert()
# Read the JSON file, validate for correctness and add the entries to
# our DB.
if self._args.server_list is not None:
try:
server_file = open(self._args.server_list, 'r')
json_data = server_file.read()
server_file.close()
except IOError:
self._smgr_log.log(self._smgr_log.ERROR,
"Error reading initial config file %s") \
% (self._args.server_list)
exit()
try:
self.config_data = json.loads(json_data)
self._smgr_log.log(self._smgr_log.DEBUG,
"Server list is %s" % self.config_data)
except Exception as e:
print repr(e)
self._smgr_log.log(self._smgr_log.ERROR,
"Initial config file %s format error. "
"File should be in JSON format") \
% (self._args.server_list)
exit()
# Validate the config for sematic correctness.
self._validate_config(self.config_data)
# Store the initial configuration in our DB
try:
self._create_server_manager_config(self.config_data)
except Exception as e:
print repr(e)
if self._is_monitoring_enabled(self._args.monitoring):
self._monitoring_base_plugin_obj.initialize_features(sm_args=self._args, serverdb=self._serverDb)
self._base_url = "http://%s:%s" % (self._args.listen_ip_addr,
self._args.listen_port)
self._pipe_start_app = bottle.app()
# All bottle routes to be defined here...
# REST calls for GET methods (Get Info about existing records)
bottle.route('/all', 'GET', self.get_server_mgr_config)
bottle.route('/cluster', 'GET', self.get_cluster)
bottle.route('/server', 'GET', self.get_server)
bottle.route('/image', 'GET', self.get_image)
bottle.route('/status', 'GET', self.get_status)
bottle.route('/server_status', 'GET', self.get_server_status)
bottle.route('/chassis-id', 'GET', self.get_server_chassis_id)
bottle.route('/tag', 'GET', self.get_server_tags)
bottle.route('/columns', 'GET', self.get_table_columns)
if self._server_monitoring_obj:
bottle.route('/MonitorConf', 'GET', self._server_monitoring_obj.get_mon_conf_details)
bottle.route('/MonitorInfo', 'GET', self._server_monitoring_obj.get_monitoring_info)
bottle.route('/MonitorInfoSummary', 'GET', self._server_monitoring_obj.get_monitoring_info_summary)
if self._server_inventory_obj:
bottle.route('/InventoryConf', 'GET', self._server_inventory_obj.get_inv_conf_details)
bottle.route('/InventoryInfo', 'GET', self._server_inventory_obj.get_inventory_info)
bottle.route('/defaults', 'GET', self.get_defaults)
#bottle.route('/logs/<filepath:path>', 'GET', self.get_defaults)
@route('/logs/<filename:re:.*>')
def callback(filename):
colorinfo = ['<tr style = "background-color:skyblue">','<tr>'] #CSS to color alternate rows
show_hidden = False
serve_path = "/var/log/contrail-server-manager/provision"
i=1 #To alternate background color
path = serve_path + filename
html = '''<html>
<head><title>Listing</title>
<style>
</style>
</head>
<body><a href = '..'>Previous Folder</a><br><hr>
<table border=0>'''
cwd = os.getcwd()
if(os.path.isfile(path)):
if(os.path.split(path)[-1][0]=='.' and show_hidden==False): #Allow accessing hidden files?
return "404! Not found."
bottle.response.set_header('Content-Type', 'text/plain')
with open(serve_path+ filename) as f: # <-- you'll need the correct path here, possibly including "articles"
stat_art = f.read()
return stat_art #serve a file
else:
try:
os.chdir(path)
files = filter(os.path.isfile, glob.glob("*"))
dirs = filter(os.path.isdir, glob.glob("*"))
objs = files + dirs
objs.sort(key=lambda x: os.path.getmtime(x))
for x in objs:
if x==os.path.split(__file__)[-1] or (x[0]=='.' and show_hidden==False): #Show hidden files?
continue
scheme = bottle.request.urlparts[0] #get the scheme of the requested url
host = bottle.request.urlparts[1] #get the hostname of the requested url
if i==0: #alternate rows are colored
i+=1
else:
i=0
#just html formatting :D
file_mod_time = time.strftime('%a, %d %b %Y %H:%M:%S +0000"', time.gmtime(os.path.getmtime(x)))
html = html+colorinfo[i]+"<td><a href = '"+scheme+"://"+host+"/logs/"+filename+"/"+x+"'>"+x+"</a></td><td>" + file_mod_time +"</td></tr>"
except Exception as e: #Actually an error accessing the file or switching to the directory
html = "404! Not found."
finally:
os.chdir(cwd)
os.chdir(cwd)
return html+"</table><hr><br><br></body></html>" #Append the remaining html code
# REST calls for PUT methods (Create New Records)
bottle.route('/all', 'PUT', self.create_server_mgr_config)
bottle.route('/image/upload', 'PUT', self.upload_image)
bottle.route('/status', 'PUT', self.put_status)
#smgr_add
bottle.route('/server', 'PUT', self.put_server)
bottle.route('/image', 'PUT', self.put_image)
bottle.route('/cluster', 'PUT', self.put_cluster)
bottle.route('/tag', 'PUT', self.put_server_tags)
# REST calls for DELETE methods (Remove records)
bottle.route('/cluster', 'DELETE', self.delete_cluster)
bottle.route('/server', 'DELETE', self.delete_server)
bottle.route('/image', 'DELETE', self.delete_image)
# REST calls for POST methods
if self._smgr_cobbler:
bottle.route('/server/reimage', 'POST', self.reimage_server)
bottle.route('/server/restart', 'POST', self.restart_server)
bottle.route('/dhcp_event', 'POST', self.process_dhcp_event)
bottle.route('/server/provision', 'POST', self.provision_server)
bottle.route('/interface_created', 'POST', self.interface_created)
if self._server_inventory_obj:
bottle.route('/run_inventory', 'POST', self._server_inventory_obj.run_inventory)
def get_pipe_start_app(self):
return self._pipe_start_app
# end get_pipe_start_app
def get_server_ip(self):
return self._args.listen_ip_addr
# end get_server_ip
def get_server_port(self):
return self._args.listen_port
# end get_server_port
# REST API call to get sever manager config - configuration of all
# clusters & all servers is returned.
def get_server_mgr_config(self):
self._smgr_log.log(self._smgr_log.DEBUG, "get_server_mgr_config")
config = {}
try:
query_args = parse_qs(urlparse(bottle.request.url).query,
keep_blank_values=True)
# Check if request arguments has detail parameter
detail = ("detail" in query_args)
config['cluster'] = self._serverDb.get_cluster(detail=detail)
config['server'] = self._serverDb.get_server(detail=detail)
config['image'] = self._serverDb.get_image(detail=detail)
# always call get_server_tags with detail=True
config['tag'] = self._serverDb.get_server_tags(detail=True)
except Exception as e:
self._smgr_trans_log.log(bottle.request, self._smgr_trans_log.GET_SMGR_ALL,
False)
self.log_trace()
resp_msg = self.form_operartion_data(repr(e), ERR_GENERAL_ERROR, None)
abort(404, resp_msg)
self._smgr_trans_log.log(bottle.request, self._smgr_trans_log.GET_SMGR_CFG_ALL)
self._smgr_log.log(self._smgr_log.DEBUG, "Config returned: %s" % (config))
return config
# end get_server_mgr_config
def get_table_columns(self):
self._smgr_log.log(self._smgr_log.DEBUG, "get_table_columns")
query_args = parse_qs(urlparse(request.url).query,
keep_blank_values=True)
table_name = query_args.get('table', None)
if not table_name:
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_TABLE_COLUMNS,
False)
resp_msg = self.form_operartion_data('table not present', ERR_GENERAL_ERROR, None)
abort(404, resp_msg)
table_columns = self._serverDb.get_table_columns(table_name[0])
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_TABLE_COLUMNS)
self._smgr_log.log(self._smgr_log.DEBUG, "Db returned columns for %s: %s" % (table_name[0], table_columns))
return table_columns
# end get_table_columns
# REST API call to get sever manager config - configuration of all
# CLUSTERs, with all servers and roles is returned. This call
# provides all the configuration as in get_server_mgr_config() call
# above. This call additionally provides a way of getting all the
# configuration for a particular cluster.
def get_cluster(self):
self._smgr_log.log(self._smgr_log.DEBUG, "get_cluster")
try:
ret_data = self.validate_smgr_request("CLUSTER", "GET",
bottle.request)
if ret_data["status"] == 0:
match_key = ret_data["match_key"]
match_value = ret_data["match_value"]
select_clause = ret_data["select"]
match_dict = {}
if match_key:
match_dict[match_key] = match_value
detail = ret_data["detail"]
entity = self._serverDb.get_cluster(
match_dict, detail=detail,
field_list=select_clause)
except ServerMgrException as e:
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_CLUSTER,
False)
resp_msg = self.form_operartion_data(e.msg, ERR_IMG_TYPE_INVALID,
None)
abort(404, resp_msg)
except Exception as e:
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_CLUSTER,
False)
self.log_trace()
resp_msg = self.form_operartion_data(repr(e), ERR_GENERAL_ERROR, None)
abort(404, resp_msg)
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_CLUSTER,
False)
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_CLUSTER)
for x in entity:
if x.get("parameters", None) is not None:
x['parameters'] = eval(x['parameters'])
self._smgr_log.log(self._smgr_log.DEBUG, "Entity returned: %s" % (print_rest_response(entity)))
return {"cluster": entity}
# end get_cluster
# REST API call to get list of server tags. The tags are read from
# .ini file and stored in DB. There is also a copy maintained in a
# dictionary. Since all these are synced up, we return info from
# dictionaty variable itself.
def get_server_tags(self):
self._smgr_log.log(self._smgr_log.DEBUG, "get_server_tags")
try:
query_args = parse_qs(urlparse(bottle.request.url).query,
keep_blank_values=True)
tag_dict = self._tags_dict.copy()
except Exception as e:
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_TAG,
False)
self.log_trace()
resp_msg = self.form_operartion_data(repr(e), ERR_GENERAL_ERROR,
None)
abort(404, resp_msg)
self._smgr_trans_log.log(bottle.request,
self._smgr_trans_log.GET_SMGR_CFG_TAG)
self._smgr_log.log(self._smgr_log.DEBUG, "Entity returned: %s" % (tag_dict))
return tag_dict
# end get_server_tags
def validate_smgr_entity(self, type, entity):
obj_list = entity.get(type, None)
if obj_list is None:
msg = "%s data not available in JSON" % \
type
self.log_and_raise_exception(msg)
def validate_smgr_get(self, validation_data, request, data=None):
ret_data = {}
ret_data['status'] = 1
query_args = parse_qs(urlparse(request.url).query,
keep_blank_values=True)
detail = ("detail" in query_args)
query_args.get("detail", None)
match_key = None
match_value = None
select_clause = self.get_select_clause(query_args)
if ((detail == True and len(query_args) == 1) or\
(detail == False and len(query_args) == 0) or\
(detail == False and len(query_args) == 1 and select_clause)):
ret_data["status"] = 0
ret_data["match_key"] = match_key
ret_data["match_value"] = match_value
ret_data["detail"] = detail
elif len(query_args) >= 1:
match_keys_str = validation_data['match_keys']
match_keys = eval(match_keys_str)
match_values = []
matches = self.validate_smgr_keys(query_args, match_keys)
self._smgr_log.log(self._smgr_log.DEBUG,
"match key returned: %s" % (matches))
self._smgr_log.log(self._smgr_log.DEBUG,
"select keys: %s" %(select_clause))
match_key, match_values = matches.popitem()
#TODO, Do we need this ?
# Append "discovered" as one of the values, though
# its not part of server table fields.
match_keys.append("discovered")
if (match_key not in match_keys):
raise ServerMgrException("Match Key not present", ERR_MATCH_KEY_NOT_PRESENT)
if match_values == None or match_values[0] == '':
raise ServerMgrException("Match Value not Specified",
ERR_MATCH_VALUE_NOT_PRESENT)
ret_data["status"] = 0
ret_data["match_key"] = match_key
ret_data["match_value"] = match_values[0]
ret_data["detail"] = detail
# end elif
ret_data['select'] = select_clause
return ret_data
def validate_smgr_put(self, validation_data, request, data=None,
modify = False):
ret_data = {}
ret_data['status'] = 1
try:
json_data = json.load(request.body)
except ValueError as e :
msg = "Invalid JSON data : %s " % e
self.log_and_raise_exception(msg)
entity = request.json
#check if json data is present
if (not entity):
msg = "No JSON data specified"
self.log_and_raise_exception(msg)
#Check if object is present
obj_name = validation_data['obj_name']
objs = entity.get(obj_name)
if len(objs) == 0:
msg = ("No %s data specified") % \
(obj_name)
self.log_and_raise_exception(msg)
#check if primary_keys are present
primary_keys_str = validation_data['primary_keys']
primary_keys = eval(primary_keys_str)
for primary_key in primary_keys:
if primary_key not in data:
msg = ("Primary Key %s not present") % (primary_key)
self.log_and_raise_exception(msg)
#Parse for the JSON to find allowable fields
remove_list = []
#new default code
if modify == False:
#pick the object defaults
obj_defaults = self._cfg_defaults_dict[obj_name]
obj_code_defaults = self._code_defaults_dict[obj_name]
#call the merge
self.merge_dict(data, obj_defaults)
self.merge_dict(data, obj_code_defaults)
obj_params_str = obj_name + "_params"
for k, v in data.iteritems():
#If json data name is not present in list of
#allowable fields silently ignore them.
if k not in validation_data:
# data.pop(k, None)
remove_list.append(k)
msg = ("Value %s is not an option") % (k)
self._smgr_log.log(self._smgr_log.ERROR,
msg)
if v == '""':
data[k] = ''
for item in remove_list:
data.pop(item, None)
if 'roles' in data:
if 'storage-compute' in data['roles'] and 'compute' not in data['roles']:
msg = "role 'storage-compute' needs role 'compute' in provision file"
raise ServerMgrException(msg, ERR_OPR_ERROR)
elif 'storage-master' in data['roles'] and 'openstack' not in data['roles']:
msg = "role 'storage-master' needs role 'openstack' in provision file"
raise ServerMgrException(msg, ERR_OPR_ERROR)
if 'toragent' in data['roles'] and 'compute' not in data['roles']:
msg = "role 'toragent' needs role 'compute' in provision file"
raise ServerMgrException(msg, ERR_OPR_ERROR)
if 'tsn' in data['roles'] and 'compute' not in data['roles']:
msg = "role 'tsn' needs role 'compute' in provision file"
raise ServerMgrException(msg, ERR_OPR_ERROR)
return ret_data
def validate_smgr_delete(self, validation_data, request, data = None):
ret_data = {}
ret_data['status'] = 1
match_keys_str = validation_data['match_keys']
match_keys = eval(match_keys_str)
query_args = parse_qs(urlparse(request.url).query,
keep_blank_values=True)
# Get the query argument.
force = ("force" in query_args)
query_args.pop("force", None)
matches = self.validate_smgr_keys(query_args, match_keys)
match_key, match_values = matches.popitem()
ret_data["status"] = 0
ret_data["match_key"] = match_key
ret_data["match_value"] = match_values[0]
ret_data["force"] = force
return ret_data
def _validate_roles(self, cluster_id):
# get list of all servers in this cluster
servers = self._serverDb.get_server(
{'cluster_id': cluster_id}, detail=True)
role_list = [
"database", "openstack", "config",
"control", "collector", "webui", "compute" ]
roles_set = set(role_list)
optional_role_list = ["storage-compute", "storage-master", "tsn", "toragent"]
optional_role_set = set(optional_role_list)
cluster_role_list = []
for server in servers:
if 'roles' in server and server['roles']:
role_list = eval(server['roles'])
else:
role_list = []
duplicate_roles = self.list_duplicates(role_list)
if len(duplicate_roles):
msg = "Duplicate Roles '%s' present" % \
", ".join(str(e) for e in duplicate_roles)
self.log_and_raise_exception(msg)
cluster_role_list.extend(role_list)
cluster_unique_roles = set(cluster_role_list)
missing_roles = roles_set.difference(cluster_unique_roles)
if len(missing_roles):
msg = "Mandatory roles \"%s\" are not present" % \
", ".join(str(e) for e in missing_roles)
self.log_and_raise_exception(msg)
unknown_roles = cluster_unique_roles.difference(roles_set)
unknown_roles.difference_update(optional_role_set)
if len(unknown_roles):
msg = "Unknown Roles: %s" % \
", ".join(str(e) for e in unknown_roles)
self.log_and_raise_exception(msg)
return 0
def list_duplicates(self, seq):
seen = set()
seen_add = seen.add
# adds all elements it doesn't know yet to seen and all other to
# seen_twice
seen_twice = set( x for x in seq if x in seen or seen_add(x) )
# turn the set into a list (as requested)
return list( seen_twice )
def validate_smgr_provision(self, validation_data, request , data=None):
ret_data = {}
ret_data['status'] = 1
entity = request.json
package_image_id = entity.get("package_image_id", '')
if package_image_id:
self.get_package_image(package_image_id)
#if package_image_id is None:
# msg = "No contrail package specified for provisioning"
# raise ServerMgrException(msg)
req_provision_params = entity.get("provision_parameters", None)
# if req_provision_params are specified, check contents for
# validity, store the info in DB and proceed with the
# provisioning step.
if req_provision_params is not None:
role_list = [
"database", "openstack", "config",
"control", "collector", "webui", "compute", "zookeeper",
"storage-compute", "storage-master", "tsn", "toragent"]
roles = req_provision_params.get("roles", None)
if roles is None:
msg = "No provisioning roles specified"
self.log_and_raise_exception(msg)
if (type(roles) != type({})):
msg = "Invalid roles definition"
self.log_and_raise_exception(msg)
prov_servers = {}
for key, value in roles.iteritems():
if key not in role_list:
msg = "invalid role %s in provision file" %(
key)
self.log_and_raise_exception(msg)
if type(value) != type ([]):
msg = "role %s needs to have server list" %(
key)
self.log_and_raise_exception(msg)
for server in value:
if server not in prov_servers:
prov_servers[server] = [key]
else:
prov_servers[server].append(key)
# end for server
# end for key
cluster_id = None
servers = []
for key in prov_servers:
server = self._serverDb.get_server(
{"id" : key}, detail=True)
if server:
server = server[0]
servers.append(server)
if ((cluster_id != None) and
(server['cluster_id'] != cluster_id)):
msg = "all servers must belong to same cluster"
self.log_and_raise_exception(msg)
cluster_id = server['cluster_id']
# end for
ret_data["cluster_id"] = cluster_id
#Modify the roles
for key, value in prov_servers.iteritems():
new_server = {
'id' : key,
'roles' : value }
self._serverDb.modify_server(new_server)
# end for
if len(servers) == 0:
msg = "No servers found"
self.log_and_raise_exception(msg)
ret_data["status"] = 0
ret_data["servers"] = servers
ret_data["package_image_id"] = package_image_id
else:
matches = self.validate_smgr_keys(entity)
match_key, match_value = matches.popitem()
# match_value = match_values[0]
# end else
match_dict = {}
if match_key == "tag":
match_dict = self._process_server_tags(match_value)
elif match_key:
match_dict[match_key] = match_value
servers = self._serverDb.get_server(
match_dict, detail=True)
if len(servers) == 0:
msg = "No servers found for %s" % \
(match_value)
self.log_and_raise_exception(msg)
cluster_id = servers[0]['cluster_id']
if not cluster_id:
msg = ("No Cluster associated with server %s") % (match_value)
self.log_and_raise_exception(msg)
self._validate_roles(cluster_id)
ret_data["status"] = 0
ret_data["servers"] = servers
ret_data["cluster_id"] = cluster_id
ret_data["package_image_id"] = package_image_id
ret_data['server_packages'] = \
self.get_server_packages(servers, package_image_id)
return ret_data
# end validate_smgr_provision
def validate_smgr_reboot(self, validation_data, request , data=None):
ret_data = {}
ret_data['status'] = 1
entity = request.json
# Get parameter to check if netboot should be enabled.
net_boot = entity.get("net_boot", None)
if ((not net_boot) or
(net_boot not in ["y","Y","1"])):
net_boot = False
else:
net_boot = True
matches = self.validate_smgr_keys(entity)
match_key, match_value = matches.popitem()
ret_data['status'] = 0
ret_data['match_key'] = match_key
ret_data['match_value'] = match_value
ret_data['net_boot'] = net_boot
return ret_data
# end else
def validate_smgr_reimage(self, validation_data, request , data=None):
ret_data = {}
ret_data['status'] = 1
entity = request.json
# Get parameter to check server(s) are to be rebooted
# following reimage configuration in cobbler. Default is yes.
do_reboot = True
no_reboot = entity.get("no_reboot", None)