This commit is contained in:
@@ -75,18 +75,19 @@ def Is_the_server_already_wanted_state(id_machine, wanted_state,instance_type):
|
|||||||
return bool_result
|
return bool_result
|
||||||
|
|
||||||
def all_operations(request,wanted_state,list_machine):
|
def all_operations(request,wanted_state,list_machine):
|
||||||
info_to_display = ""
|
|
||||||
if wanted_state == "running":
|
|
||||||
operation_to_perform = "start"
|
|
||||||
elif wanted_state == "stopped":
|
|
||||||
operation_to_perform = "stop"
|
|
||||||
else:
|
|
||||||
print("Incorrect wanted state")
|
|
||||||
|
|
||||||
|
|
||||||
for machine_target in list_machine:
|
for machine_target in list_machine:
|
||||||
print(machine_target[1])
|
print(machine_target[1])
|
||||||
kubernetes_connection.scale_up(request,namespace_name=machine_target[0],deploy_name=machine_target[1],replicas=machine_target[2]);
|
|
||||||
|
info_to_display = ""
|
||||||
|
if wanted_state == "running":
|
||||||
|
kubernetes_connection.scale_up(request,namespace_name=machine_target[0],deploy_name=machine_target[1],replicas=machine_target[2]);
|
||||||
|
elif wanted_state == "stopped":
|
||||||
|
kubernetes_connection.scale_down(request,namespace_name=machine_target[0],deploy_name=machine_target[1],replicas=machine_target[2]);
|
||||||
|
else:
|
||||||
|
print("Incorrect wanted state")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# if not(Is_the_server_already_wanted_state(machine_target[0], wanted_state,machine_target[1])):
|
# if not(Is_the_server_already_wanted_state(machine_target[0], wanted_state,machine_target[1])):
|
||||||
# function.action(False,machine_target[0],operation_to_perform,machine_target[1])
|
# function.action(False,machine_target[0],operation_to_perform,machine_target[1])
|
||||||
# print(str(machine_target[0])+" is now "+str(wanted_state))
|
# print(str(machine_target[0])+" is now "+str(wanted_state))
|
||||||
@@ -104,7 +105,7 @@ def main(request):
|
|||||||
db_user = os.environ.get('DB_USERNAME')
|
db_user = os.environ.get('DB_USERNAME')
|
||||||
db_password = os.environ.get('DB_PASSWORD')
|
db_password = os.environ.get('DB_PASSWORD')
|
||||||
db_name = os.environ.get('CUSTOM_DB_DATABASE',os.environ.get('DB_DATABASE'))
|
db_name = os.environ.get('CUSTOM_DB_DATABASE',os.environ.get('DB_DATABASE'))
|
||||||
print(db_name)
|
|
||||||
generated_db = DB_generation(db_host, db_port, db_user, db_password,db_name)
|
generated_db = DB_generation(db_host, db_port, db_user, db_password,db_name)
|
||||||
##operation:
|
##operation:
|
||||||
## Server(s) supposed to be UP
|
## Server(s) supposed to be UP
|
||||||
@@ -115,19 +116,19 @@ def main(request):
|
|||||||
print("------------------------------------------")
|
print("------------------------------------------")
|
||||||
print(list_servers_up)
|
print(list_servers_up)
|
||||||
print(all_operations(request,"running", list_servers_up))
|
print(all_operations(request,"running", list_servers_up))
|
||||||
#
|
|
||||||
#
|
|
||||||
# ## Server(s) supposed to be DOWN
|
## Server(s) supposed to be DOWN
|
||||||
# list_servers_down = Check_server_supposed_XXX(generated_db, "down", Give_current_hour())
|
list_servers_down = Check_server_supposed_XXX(generated_db, "down", Give_current_hour())
|
||||||
#
|
|
||||||
# print("------------------------------------------")
|
print("------------------------------------------")
|
||||||
# print("----------------DOWN----------------------")
|
print("----------------DOWN----------------------")
|
||||||
# print("------------------------------------------")
|
print("------------------------------------------")
|
||||||
# print(list_servers_down)
|
print(list_servers_down)
|
||||||
# print(all_operations("stopped",list_servers_down))
|
print(all_operations("stopped",list_servers_down))
|
||||||
#
|
|
||||||
#
|
|
||||||
# # disconnect from server
|
# disconnect from server
|
||||||
generated_db.close()
|
generated_db.close()
|
||||||
|
|
||||||
#print(Is_the_server_already_wanted_state(112, "stopped"))
|
#print(Is_the_server_already_wanted_state(112, "stopped"))
|
||||||
|
|||||||
Reference in New Issue
Block a user