github/jumpserver
1
0
Fork 0
mirror of https://github.com/jumpserver/jumpserver.git synced 2025-09-20 02:51:27 +00:00
Code Issues Projects Releases Wiki Activity

fix: k8s api 500 (#10209)

Browse Source 
Co-authored-by: feng <1304903146@qq.com>
This commit is contained in:
fit2bot
2023-04-14 16:57:08 +08:00
committed by GitHub
parent 31653cab11
commit e0f077b054
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
apps/assets/utils/k8s.py
View File

@@ -4,6 +4,7 @@ from urllib.parse import urlencode
from kubernetes import client from kubernetes import client
from kubernetes.client import api_client from kubernetes.client import api_client
from kubernetes.client.api import core_v1_api from kubernetes.client.api import core_v1_api
from kubernetes.client.exceptions import ApiException
from common.utils import get_logger from common.utils import get_logger
from ..const import CloudTypes, Category from ..const import CloudTypes, Category
@@ -65,9 +66,13 @@ class KubernetesClient:
proxy_url = cls.get_proxy_url(asset) proxy_url = cls.get_proxy_url(asset)
k8s = cls(k8s_url, secret, proxy=proxy_url) k8s = cls(k8s_url, secret, proxy=proxy_url)
func_name = f'get_{tp}s' func_name = f'get_{tp}s'
data = []
if hasattr(k8s, func_name): if hasattr(k8s, func_name):
return getattr(k8s, func_name)(*args) try:
return [] data = getattr(k8s, func_name)(*args)
except ApiException as e:
logger.error(e.reason)
return data
class KubernetesTree: class KubernetesTree: