From fd5143000b359a28d55df970951451266c720987 Mon Sep 17 00:00:00 2001 From: keegansmith21 Date: Mon, 8 Jul 2024 05:25:50 +0000 Subject: [PATCH] Added the gke secret retrieval --- observatory_platform/google/gke.py | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/observatory_platform/google/gke.py b/observatory_platform/google/gke.py index f7ae3aa1c..e924d44b3 100644 --- a/observatory_platform/google/gke.py +++ b/observatory_platform/google/gke.py @@ -101,3 +101,22 @@ def gke_delete_volume(*, kubernetes_conn_id: str, volume_name: str): logging.info(f"gke_delete_volume: PersistentVolume with name={volume_name} does not exist") else: raise e + + +def gke_retrieve_secret(*, secret_name: str, namespace: str): + """Retrieves a secret from the GKE secrets backend + + :param secret_name: the name of the secret to retrieve + :param namespace: the namespace that the secret belongs to + :return: The secret + """ + v1 = client.CoreV1Api() + try: + secret = v1.read_namespaced_secret(secret_name, namespace) + except client.exceptions.ApiException as e: + if e.status == 404: + print(f"Secret '{secret_name}' not found in namespace '{namespace}'") + else: + print(f"Exception when retrieving secret: {e}") + + return secret