This commit is contained in:
@@ -16,7 +16,7 @@ Including another URLconf
|
|||||||
"""
|
"""
|
||||||
from django.urls import path
|
from django.urls import path
|
||||||
|
|
||||||
from .views import coucou,display,hello,import_namespace_view
|
from .views import coucou,display,hello,import_namespace_view,retrieve_and_apply_view
|
||||||
|
|
||||||
|
|
||||||
urlpatterns = [
|
urlpatterns = [
|
||||||
@@ -25,6 +25,6 @@ urlpatterns = [
|
|||||||
path('coucou', coucou, name='coucou'),
|
path('coucou', coucou, name='coucou'),
|
||||||
path('display', display, name='display'),
|
path('display', display, name='display'),
|
||||||
path('import_namespace', import_namespace_view, name='import_namespace'),
|
path('import_namespace', import_namespace_view, name='import_namespace'),
|
||||||
|
path('retrieve_and_apply_view', retrieve_and_apply_view, name='retrieve_and_apply_view'),
|
||||||
|
|
||||||
]
|
]
|
||||||
|
|||||||
@@ -98,6 +98,10 @@ def Check_server_supposed_XXX(expected_status,verbose=False):
|
|||||||
|
|
||||||
def retrieve_and_apply(verbose=False):
|
def retrieve_and_apply(verbose=False):
|
||||||
|
|
||||||
|
output =+ Give_current_hour()
|
||||||
|
output += "\n"
|
||||||
|
|
||||||
|
|
||||||
#Get current replica to compare with the replicas created at the start
|
#Get current replica to compare with the replicas created at the start
|
||||||
get_current_replicas()
|
get_current_replicas()
|
||||||
|
|
||||||
@@ -110,7 +114,11 @@ def retrieve_and_apply(verbose=False):
|
|||||||
if server[3].actual_replica == server[2]:
|
if server[3].actual_replica == server[2]:
|
||||||
if verbose : print("name: "+str(server[1])+" namespace: "+str(server[0])+" already UP")
|
if verbose : print("name: "+str(server[1])+" namespace: "+str(server[0])+" already UP")
|
||||||
else:
|
else:
|
||||||
print("Starting -> name: "+str(server[1])+" namespace: "+str(server[0])+" replicas: "+str(server[2]))
|
echo = "Starting -> name: "+str(server[1])+" namespace: "+str(server[0])+" replicas: "+str(server[2])
|
||||||
|
output += echo
|
||||||
|
output =+ "\n"
|
||||||
|
print(echo)
|
||||||
|
|
||||||
scale_up(namespace_name=server[1],deploy_name=server[0],replicas=server[2])
|
scale_up(namespace_name=server[1],deploy_name=server[0],replicas=server[2])
|
||||||
|
|
||||||
print("------------------------------------------")
|
print("------------------------------------------")
|
||||||
@@ -122,5 +130,11 @@ def retrieve_and_apply(verbose=False):
|
|||||||
if server[3].actual_replica == 0:
|
if server[3].actual_replica == 0:
|
||||||
if verbose : print("name: "+str(server[1])+" namespace: "+str(server[0])+" already DOWN")
|
if verbose : print("name: "+str(server[1])+" namespace: "+str(server[0])+" already DOWN")
|
||||||
else:
|
else:
|
||||||
print("Shutting down -> name: "+str(server[1])+" namespace: "+str(server[0])+" replicas: "+str(server[2]))
|
|
||||||
|
echo = "Shutting down -> name: "+str(server[1])+" namespace: "+str(server[0])+" replicas: "+str(server[2])
|
||||||
|
output += echo
|
||||||
|
output =+ "\n"
|
||||||
|
print(echo)
|
||||||
scale_down(namespace_name=server[1],deploy_name=server[0])
|
scale_down(namespace_name=server[1],deploy_name=server[0])
|
||||||
|
|
||||||
|
return output
|
||||||
@@ -4,7 +4,7 @@ from django.shortcuts import render
|
|||||||
# IMPORT AT THE TOP HERE: This is completely safe!
|
# IMPORT AT THE TOP HERE: This is completely safe!
|
||||||
from .models import Deployment_Data,Schedule_Week_Data
|
from .models import Deployment_Data,Schedule_Week_Data
|
||||||
from .db_interaction import DB_generation,Check_server_supposed_XXX,Give_current_weekday,Give_current_hour
|
from .db_interaction import DB_generation,Check_server_supposed_XXX,Give_current_weekday,Give_current_hour
|
||||||
from .utils import import_namespace
|
from .utils import import_namespace,retrieve_and_apply
|
||||||
|
|
||||||
def coucou(request):
|
def coucou(request):
|
||||||
# 1. Prepare the data inside the function
|
# 1. Prepare the data inside the function
|
||||||
@@ -36,6 +36,10 @@ def import_namespace_view(request):
|
|||||||
return HttpResponse('<h1>Namespace imported!</h1>')
|
return HttpResponse('<h1>Namespace imported!</h1>')
|
||||||
|
|
||||||
|
|
||||||
|
def retrieve_and_apply_view(request):
|
||||||
|
output = retrieve_and_apply()
|
||||||
|
return HttpResponse('<h1>'+output+'</h1>')
|
||||||
|
|
||||||
def redirect(request):
|
def redirect(request):
|
||||||
db_host = os.environ.get('DB_HOST')
|
db_host = os.environ.get('DB_HOST')
|
||||||
db_port = os.environ.get('DB_PORT')
|
db_port = os.environ.get('DB_PORT')
|
||||||
|
|||||||
Reference in New Issue
Block a user