external/HyperProxmox
1
0
Fork 0
mirror of https://github.com/ThomasGsp/HyperProxmox.git synced 2025-02-15 04:32:15 +00:00
Code Issues Releases Wiki Activity

errors management + fix

Browse source
This commit is contained in:
Tlams 2018-02-11 18:40:05 +00:00
parent e5d7814a9b
commit 1ee636da81
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
code/scripts/main/core/core.py
View file

@ -49,7 +49,7 @@ class Core:
self.redis_msg.connect() self.redis_msg.connect()
self.redis_cache.connect() self.redis_cache.connect()
if self.mongo.client and self.redis_msg: if self.mongo.client and self.redis_msg.connect() and self.redis_cache.connect():
self.mongo.db = self.mongo.client.db self.mongo.db = self.mongo.client.db
""" Others """ """ Others """
@ -70,6 +70,8 @@ class Core:
args=(self.clusters_conf, self.generalconf, args=(self.clusters_conf, self.generalconf,
generalconf["analyst"]["walker"])) generalconf["analyst"]["walker"]))
thc.start() thc.start()
else:
exit(1)
""" """
@ -104,7 +106,7 @@ class Core:
hash_object = hashlib.md5("{0}-{1}-{2}-{3}-{4}".format(dest, date, cluster, node, vmid).encode('utf-8')) hash_object = hashlib.md5("{0}-{1}-{2}-{3}-{4}".format(dest, date, cluster, node, vmid).encode('utf-8'))
hash_hex = hash_object.hexdigest() hash_hex = hash_object.hexdigest()
cache = self.redis_cache.get_message(hash_hex) cache = None # self.redis_cache.get_message(hash_hex)["value"]
if cache is None or self.generalconf["logger"]["debug"] == True: if cache is None or self.generalconf["logger"]["debug"] == True:
if dest == "instances": if dest == "instances":
@ -123,6 +125,7 @@ class Core:
self.redis_cache.insert_message(hash_hex, resultmbrequest, 3600) self.redis_cache.insert_message(hash_hex, resultmbrequest, 3600)
return resultmbrequest return resultmbrequest
else: else:
print("Cache")
return cache return cache
@ -405,7 +408,7 @@ class Core:
def get_clusters_conf(self, cluster=None): def get_clusters_conf(self, cluster=None):
""" Find cluster informations from node """ """ Find cluster informations from node """
clusters_informations = self.mongo.get_clusters_conf(cluster)["value"] clusters_informations = self.mongo.get_clusters_conf(cluster)
return clusters_informations return clusters_informations
def insert_clusters_conf(self, data): def insert_clusters_conf(self, data):
@ -457,7 +460,7 @@ class Core:
def valid_clusters_data(data): def valid_clusters_data(data):
key_required = ["name", "url", "port", "user", "password", "template", "storages_disk", "weight", "exclude_nodes"] key_required = ["name", "url", "port", "user", "password", "template", "storage_disk", "weight", "exclude_nodes"]
result = [] result = []
for key in key_required: for key in key_required:
if key not in data: if key not in data: