diff --git a/README.md b/README.md index df05c0a..a2626d2 100644 --- a/README.md +++ b/README.md @@ -115,7 +115,7 @@ docker run --rm -v ~/.kube/config:/home/app/.kube/config aelbakry/kdave:latest - The Kubernetes version. If not provided, it defaults to the current cluster version ``--helm-binary`` - The helm binary to be used for running helm commands. Default is helm v2 + The helm binary to be used for running helm commands. Default is helm v2. Use "helm" for helm V2 and "helm3" for helm V3 ``--output-dir`` The output directory used to template the chart diff --git a/exporter/__init__.py b/exporter/__init__.py index b5fdc75..d31c31e 100644 --- a/exporter/__init__.py +++ b/exporter/__init__.py @@ -1 +1 @@ -__version__ = "0.2.2" +__version__ = "0.2.3" diff --git a/exporter/app.py b/exporter/app.py index f4e75d9..935e2dd 100644 --- a/exporter/app.py +++ b/exporter/app.py @@ -27,6 +27,7 @@ DEFAULT_VERSIONS_FILE, HELM_TEMPLATE_TMP_DIRECTORY, HELM_V2_BINARY, + HELM_V3_BINARY, ) from exporter.exceptions import ( DeprecatedAPIVersionError, @@ -50,6 +51,7 @@ load_yaml_file, parse_duration, put_all_releases_in_queue, + put_all_releases_v3_in_queue, ) app = Flask(__name__) @@ -250,7 +252,8 @@ def parse_semver(version: str): > parse_semver(v1.18.16) returns 1.18.16 > parse_semver(v1.21.0-alpha.1) returns 1.21.0 > parse_semver(v1.21.0-rc.0) returns 1.21.0 - If the version is not valid k8s version, it'll raise InvalidSemVerError which will be handled by other functions. + If the version is not valid k8s version, + It'll raise InvalidSemVerError which will be handled by other functions. """ if re.match(r"(v?)(\d+\.\d+\.?\d*)(.*?)", version): match = re.match(r"(v?)(\d+\.\d+\.?\d*)(.*?)", version) @@ -281,32 +284,27 @@ def _k8s_version(): return k8s_version -def check_deprecations(data: dict, k8s_version: str = None): +def check_deprecations(data: dict, k8s_version: str): """ Check the deprecated apiVersions based on the current or provided K8s version and the source of truth yaml file "versions.yaml" """ result = {} - if not k8s_version: - current_k8s_version = _k8s_version() - - version = k8s_version if k8s_version else current_k8s_version - deprecations = get_all_deprecations() if data: deprecated = ( "true" if is_deprecated_version( - data["kind"], data["apiVersion"], version, deprecations + data["kind"], data["apiVersion"], k8s_version, deprecations ) else "false" ) removed = ( "true" if is_removed_version( - data["kind"], data["apiVersion"], version, deprecations + data["kind"], data["apiVersion"], k8s_version, deprecations ) else "false" ) @@ -325,14 +323,14 @@ def check_deprecations(data: dict, k8s_version: str = None): result["kind"] = data["kind"] result["api_version"] = data["apiVersion"] result["name"] = data["metadata"]["name"] - result["k8s_version"] = version + result["k8s_version"] = k8s_version result["removed_in_next_release"] = ( "true" if is_removed_version( data["kind"], data["apiVersion"], - increment_semver(version, 1), + increment_semver(k8s_version, 1), deprecations, ) else "false" @@ -342,7 +340,7 @@ def check_deprecations(data: dict, k8s_version: str = None): if is_removed_version( data["kind"], data["apiVersion"], - increment_semver(version, 2), + increment_semver(k8s_version, 2), deprecations, ) else "false" @@ -358,6 +356,8 @@ def check_deprecations_in_files(source: str, k8s_version: str = None): """ result = [] + version = k8s_version if k8s_version else _k8s_version() + try: data = load_yaml_file(source) @@ -366,9 +366,9 @@ def check_deprecations_in_files(source: str, k8s_version: str = None): if isinstance(data, list): for dep in data: - result.append(check_deprecations(dep, k8s_version)) + result.append(check_deprecations(dep, version)) else: - result.append(check_deprecations(data, k8s_version)) + result.append(check_deprecations(data, version)) return result @@ -576,13 +576,15 @@ def raise_api_versions_exception(deprecations: List[Dict]) -> None: raise DeprecatedAPIVersionError -def get_kinds_from_helm_release(helm_binary: str, release_name: str): +def get_kinds_from_helm_release( + helm_binary: str, release_name: str, namespace: str = None +): """ - Get all kinds from a helm release a long with the apiVersions to check the deprection + Get all kinds from a helm release a long with the apiVersions to check the deprecation """ result: List = [] try: - release_info = helm_get(helm_binary, release_name) + release_info = helm_get(helm_binary, release_name, namespace) except HelmCommandError: logger.warning(f"release: {release_name} not found.") return result @@ -615,14 +617,16 @@ def get_deployed_deprecated_kinds( Get the deprecated apiVersions for the deployed kinds which are fetched from a helm release. """ result: List = [] - kinds = get_kinds_from_helm_release(helm_binary, release_name) + version = k8s_version if k8s_version else _k8s_version() + + kinds = get_kinds_from_helm_release(helm_binary, release_name, namespace) if not kinds: return result logger.info(f"Checking the used apiVersions for release: {release_name}") for _kind in kinds: - dep = check_deprecations(_kind, k8s_version) + dep = check_deprecations(_kind, version) if dep: dep["release_name"] = release_name dep["namespace"] = namespace if namespace else release_name @@ -636,6 +640,7 @@ def handle_release_deprecation( exit_event: threading.Event, lock: threading.Lock, helm_binary: str, + k8s_version: str, data: list, release_stats: list, ): @@ -649,7 +654,7 @@ def handle_release_deprecation( helm_binary, release_info["name"], release_info["namespace"], - k8s_version=None, + k8s_version=k8s_version, ) deprecated = "false" removed = "false" @@ -695,6 +700,7 @@ def get_deprecations_for_all_releases( q: queue.Queue, exit_event: threading.Event, helm_binary: str, + k8s_version: str, app_data=app_data, lock=lock, data_file: str = DATA_FILE, @@ -717,7 +723,11 @@ def get_deprecations_for_all_releases( start = time.time() put_releases_in_queue = threading.Thread( - target=put_all_releases_in_queue, + target=( + put_all_releases_v3_in_queue + if helm_binary == HELM_V3_BINARY + else put_all_releases_in_queue + ), name="put_releases_in_queue", daemon=True, kwargs={ @@ -742,6 +752,7 @@ def get_deprecations_for_all_releases( "exit_event": exit_event, "lock": _lock, "helm_binary": helm_binary, + "k8s_version": k8s_version, "data": data, "release_stats": release_stats, }, @@ -837,6 +848,7 @@ def export_deprecated_versions_metrics( q: queue.Queue, exit_event: threading.Event, helm_binary: str, + k8s_version: str, app_data: dict = app_data, lock=lock, # Manager.Lock data_file: str = DATA_FILE, @@ -853,6 +865,7 @@ def export_deprecated_versions_metrics( q, exit_event, helm_binary, + k8s_version, max=max, app_data=app_data, lock=lock, @@ -1048,7 +1061,7 @@ def get_arguments(): parser.add_argument( "-b", "--helm-binary", - help="The helm binary to be used for running helm commands. Default is helm v2.", + help='The helm binary to be used for running helm commands.Default is helm v2. Use "helm" for helm V2 and "helm3" for helm V3', type=str, default=HELM_V2_BINARY, ) @@ -1069,6 +1082,7 @@ def get_arguments(): app_server = WSGIServer((args.address, args.port), app) logger.info("Starting kdave server.") logger.info(f"Running on http://{args.address}:{args.port}/") + k8s_version = _k8s_version() flask_app = multiprocessing.Process( name="flask-app", target=app_server.serve_forever @@ -1076,7 +1090,7 @@ def get_arguments(): helm = multiprocessing.Process( name="helm-handler", target=export_deprecated_versions_metrics, - args=(args.threads, q, exit_event, helm_binary), + args=(args.threads, q, exit_event, helm_binary, k8s_version), kwargs={"data_file": args.data_file, "max": args.max}, ) diff --git a/exporter/helper.py b/exporter/helper.py index a486c25..c53ffc3 100644 --- a/exporter/helper.py +++ b/exporter/helper.py @@ -283,12 +283,17 @@ def helm_list_namespace_releases(helm_binary: str, namespace: str): "yaml", ] cmd = _run_helm_command(helm_command) - releases_info = yaml.safe_load(cmd) - if releases_info: - releases = releases_info["Releases"] + releases = yaml.safe_load(cmd) + + if releases: + if helm_binary != HELM_V3_BINARY: + releases = releases["Releases"] for release in releases: - _releases.append(release["Name"]) + release_name = ( + release["name"] if helm_binary == HELM_V3_BINARY else release["Name"] + ) + _releases.append(release_name) return _releases @@ -316,9 +321,37 @@ def put_all_releases_in_queue( exit_event.set() +def put_all_releases_v3_in_queue( + helm_binary: str, q: queue.Queue, exit_event: threading.Event, max: int +): + exit_event.clear() + + all_releases = helm_list_all_releases(helm_binary, max) + releases = yaml.safe_load(all_releases) + + if releases: + for release in releases: + put_release_in_queue(q, release) + next = max + remaining_releases = yaml.safe_load( + helm_list_all_releases(helm_binary, max, next) + ) + while remaining_releases: + for release in remaining_releases: + put_release_in_queue(q, release) + next = next + max + remaining_releases = yaml.safe_load( + helm_list_all_releases(helm_binary, max, next) + ) + + while not q.empty(): + pass + + exit_event.set() + + @retry(HelmCommandError, total_tries=10, delay=5) -def helm_list_all_releases(helm_binary: str, max: int = None, offset: str = None): - releases = {} +def helm_list_all_releases(helm_binary: str, max: int, offset: str = None): helm_command = [helm_binary, "list", "--output", "yaml"] if helm_binary == HELM_V3_BINARY: helm_command.extend(["--all-namespaces"]) @@ -326,7 +359,7 @@ def helm_list_all_releases(helm_binary: str, max: int = None, offset: str = None helm_command.extend(["--max", str(max)]) if offset: - helm_command.extend(["--offset", offset]) + helm_command.extend(["--offset", str(offset)]) releases = _run_helm_command(helm_command) @@ -336,20 +369,45 @@ def helm_list_all_releases(helm_binary: str, max: int = None, offset: str = None def put_release_in_queue(q: queue.Queue, release: dict): q.put( { - "name": release["Name"], - "namespace": release["Namespace"], - "release_last_update": release["Updated"], + "name": release["Name"] if ("Name" in release) else release["name"], + "namespace": release["Namespace"] + if ("Namespace" in release) + else release["namespace"], + "release_last_update": release["Updated"] + if ("Updated" in release) + else release["updated"], } ) -def helm_get(helm_binary: str, release_name: str): +def helm_get(helm_binary: str, release_name: str, namespace: str = None): helm_command = [helm_binary, "get", "manifest", release_name] + if helm_binary == HELM_V3_BINARY: + if not namespace: + logger.info( + "The namespace is required in helm v3. " + "Defaulting to the release name since the namespace is not provided." + ) + namespace = release_name + + helm_command.extend(["--namespace", namespace]) + return _run_helm_command(helm_command) -def helm_release_exists(helm_binary: str, release_name: str) -> bool: +def helm_release_exists( + helm_binary: str, release_name: str, namespace: str = None +) -> bool: helm_command = [helm_binary, "get", release_name] + if helm_binary == HELM_V3_BINARY: + if not namespace: + logger.info( + "The namespace is required in helm v3. " + "Defaulting to the release name since the namespace is not provided." + ) + namespace = release_name + + helm_command.extend(["--namespace", namespace]) try: _run_helm_command(helm_command) except HelmCommandError: diff --git a/exporter/manage.py b/exporter/manage.py index dde8085..04a0f1a 100644 --- a/exporter/manage.py +++ b/exporter/manage.py @@ -84,7 +84,7 @@ def cli(ctx, debug): "--helm-binary", "helm_binary", default=HELM_V2_BINARY, - help="The helm binary to be used for running helm commands. Default is helm v2.", + help='The helm binary to be used for running helm commands.Default is helm v2. Use "helm" for helm V2 and "helm3" for helm V3', ) @click.option( "--custom-values", diff --git a/requirements.txt b/requirements.txt index 75878ab..2616dca 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,5 +1,5 @@ kubernetes==11.0.0 -Click==8.0 +Click==8.0.2 terminaltables==3.1.0 semver==2.13.0 Flask==2.1.0 diff --git a/tests/test_app.py b/tests/test_app.py index aa8396d..94f3603 100644 --- a/tests/test_app.py +++ b/tests/test_app.py @@ -529,6 +529,7 @@ def test_get_deprecations_for_all_releases__update_existing_data__success(mocker app.queue.Queue, app.threading.Event(), HELM_V2_BINARY, + "v1.21.0", app_data=app.app_data, lock=app.lock, data_file="tests/fixtures/data.json", @@ -563,6 +564,7 @@ def test_export_deprecated_versions_metrics__success(mocker): mocked_queue, mocked_exit_event, HELM_V2_BINARY, + "v1.21.0", app_data=app.app_data, lock=mocked_lock, data_file="tests/fixtures/data.json", @@ -574,6 +576,7 @@ def test_export_deprecated_versions_metrics__success(mocker): mocked_queue, mocked_exit_event, HELM_V2_BINARY, + "v1.21.0", app_data=app.app_data, lock=mocked_lock, data_file="tests/fixtures/data.json",