Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Code enhancements #51

Open
wants to merge 3 commits into
base: main
Choose a base branch
from
Open

Code enhancements #51

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
43f747d
Docstrings and fstrings changes
Mar 14, 2023
86a96f9
using default file permissions
Mar 14, 2023
b7f6e24
updating few lines as per the latest branch
Mar 15, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions remote_monitoring_demo/demo.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,12 +17,11 @@
from kruize.kruize import *
import sys, getopt
import json
import os
import time

def generate_json(find_arr, json_file, filename, i):

with open(json_file, 'r') as file:
with open(json_file) as file:
data = file.read()

for find in find_arr:
Expand All @@ -45,8 +44,9 @@ def main(argv):

print(find)


try:
opts, args = getopt.getopt(argv,"h:c:")
opts, _ = getopt.getopt(argv,"h:c:")
except getopt.GetoptError:
print("demo.py -c <cluster type>")
sys.exit(2)
Expand Down
72 changes: 44 additions & 28 deletions remote_monitoring_demo/kruize/kruize.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,7 @@
import subprocess
import requests
import json
import os
import time
import shutil


def form_kruize_url(cluster_type):
global URL
Expand All @@ -43,14 +41,17 @@ def form_kruize_url(cluster_type):
print("IP = ", SERVER_IP)

URL = "http://" + str(SERVER_IP) + ":" + str(AUTOTUNE_PORT)
print ("\nKRUIZE AUTOTUNE URL = ", URL)
print (f"\nKRUIZE AUTOTUNE URL = {URL}")


# Description: This function validates the input json and posts the experiment using createExperiment API to Kruize
# Input Parameters: experiment input json
def create_experiment(input_json_file):
"""
Description: This function validates the input json and posts
the experiment using createExperiment API to Kruize
Input Parameters: experiment input json
"""

json_file = open(input_json_file, "r")
json_file = open(input_json_file)
input_json = json.loads(json_file.read())
print("\n************************************************************")
print(input_json)
Expand All @@ -68,15 +69,18 @@ def create_experiment(input_json_file):
print("\nCreating the experiment...")

url = URL + "/createExperiment"
print("URL = ", url)
print(f"URL = {url}")

response = requests.post(url, json=input_json)
print("Response status code = ", response.status_code)
print(f"Response status code = {response.status_code}")
print(response.text)

# Description: This function validates the result json and posts the experiment results using updateResults API to Kruize
# Input Parameters: resource usage metrics json
def update_results(result_json_file):
"""
Description: This function validates the result json and
posts the experiment results using updateResults API to Kruize
Input Parameters: resource usage metrics json
"""

# read the json
json_file = open(result_json_file, "r")
Expand All @@ -86,60 +90,72 @@ def update_results(result_json_file):

print("\nUpdating the results...")
url = URL + "/updateResults"
print("URL = ", url)
print(f"URL = {url}")

response = requests.post(url, json=result_json)
print("Response status code = ", response.status_code)
print(f"Response status code = {response.status_code}")
print(response.text)
return response

# Description: This function obtains the recommendations from Kruize using listRecommendations API
# Input Parameters: experiment name
def list_recommendations(experiment_name):
"""
Description: This function obtains the recommendations
from Kruize using listRecommendations API
Input Parameters: experiment name, deployment name and namespace
"""

print("\nListing the recommendations...")
url = URL + "/listRecommendations"
print("URL = ", url)
print(f"URL = {url}")

PARAMS = {'experiment_name': experiment_name}
response = requests.get(url = url, params = PARAMS)
print("Response status code = ", response.status_code)
print(f"Response status code = {response.status_code}")

return response.json()

# Description: This function creates a performance profile using the Kruize createPerformanceProfile API
# Input Parameters: performance profile json
def create_performance_profile(perf_profile_json_file):
"""
Description: This function creates a performance profile
using the Kruize createPerformanceProfile API
Input Parameters: performance profile json
"""

json_file = open(perf_profile_json_file, "r")
json_file = open(perf_profile_json_file)
perf_profile_json = json.loads(json_file.read())

print("\nCreating performance profile...")
url = URL + "/createPerformanceProfile"
print("URL = ", url)
print(f"URL = {url}")

response = requests.post(url, json=perf_profile_json)
print("Response status code = ", response.status_code)
print(f"Response status code = {response.status_code}")
print(response.text)
return response

# Description: This function obtains the experiments and result metrics from Kruize using listExperiments API
def list_experiments():
"""
Description: This function obtains the experiments and
result metrics from Kruize using listExperiments API
"""

print("\nListing the experiments...")
url = URL + "/listExperiments"
print("URL = ", url)
print(f"URL = {url}")

response = requests.get(url = url)
print("Response status code = ", response.status_code)
print(f"Response status code = {response.status_code}")

return response.json()

# Description: This function combines the metric results and recommendations into a single json
# Input parameters: result json file, recommendations json
def combine_jsons(result_json, reco_json):
"""
Description: This function combines the metric
results and recommendations into a single json
Input parameters: result json file, recommendations json
"""

input_json = open(result_json, "r")
input_json = open(result_json)
data = json.loads(input_json.read())

exp = "quarkus-resteasy-autotune-min-http-response-time-db"
Expand Down