[j4dZddlmZdZdZdZd dZd dZdS) z Metrics utilities for Kubernetes resource monitoring. Provides helpers for fetching and processing resource usage data from the metrics.k8s.io API endpoint, enabling monitoring and autoscaling workflows. )CustomObjectsApizmetrics.k8s.iov1beta1cdt|}|ttdS)aM Fetch current resource usage for all cluster nodes. Retrieves CPU and memory consumption metrics from the metrics-server for every node in the cluster. Parameters: api_client: An initialized kubernetes.client.ApiClient instance Returns: A dictionary containing the metrics response with structure: { 'kind': 'NodeMetricsList', 'apiVersion': 'metrics.k8s.io/v1beta1', 'metadata': {...}, 'items': [ { 'metadata': {'name': 'node-1', ...}, 'timestamp': '2024-01-01T00:00:00Z', 'window': '30s', 'usage': {'cpu': '100m', 'memory': '1024Mi'} }, ... ] } Raises: ApiException: If the metrics server is not available or request fails Example: >>> from kubernetes import client, config >>> config.load_kube_config() >>> api_client = client.ApiClient() >>> metrics = get_nodes_metrics(api_client) >>> for node in metrics['items']: ... name = node['metadata']['name'] ... cpu = node['usage']['cpu'] ... mem = node['usage']['memory'] ... print(f"Node {name}: CPU={cpu}, Memory={mem}") nodes)groupversionplural)rlist_cluster_custom_objectMETRICS_API_GROUPMETRICS_API_VERSION) api_clientapis U/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/kubernetes/utils/metrics.pyget_nodes_metricsrs8R : & &C  ) )# *  Nc|stdt|}tt|dd}|r||d<|jdi|S)a Fetch current resource usage for pods in a namespace. Retrieves CPU and memory consumption metrics from the metrics-server for pods in the specified namespace, with optional label filtering. Parameters: api_client: An initialized kubernetes.client.ApiClient instance namespace: The namespace name to query (required) label_selector: Optional label query to filter pods (e.g., 'app=web,env=prod') Returns: A dictionary containing the metrics response with structure: { 'kind': 'PodMetricsList', 'apiVersion': 'metrics.k8s.io/v1beta1', 'metadata': {...}, 'items': [ { 'metadata': {'name': 'pod-1', 'namespace': 'default', ...}, 'timestamp': '2024-01-01T00:00:00Z', 'window': '30s', 'containers': [ { 'name': 'container-1', 'usage': {'cpu': '50m', 'memory': '512Mi'} }, ... ] }, ... ] } Raises: ValueError: If namespace is None or empty ApiException: If the metrics server is not available or request fails Example: >>> from kubernetes import client, config >>> config.load_kube_config() >>> api_client = client.ApiClient() >>> >>> # Get all pods in namespace >>> metrics = get_pods_metrics(api_client, 'default') >>> >>> # Get pods with specific labels >>> metrics = get_pods_metrics(api_client, 'default', 'app=nginx') >>> >>> for pod in metrics['items']: ... pod_name = pod['metadata']['name'] ... print(f"Pod: {pod_name}") ... for container in pod['containers']: ... cname = container['name'] ... cpu = container['usage']['cpu'] ... mem = container['usage']['memory'] ... print(f" Container {cname}: CPU={cpu}, Memory={mem}") z3namespace parameter is required and cannot be emptypods)rr namespacer label_selector) ValueErrorrr r list_namespaced_custom_object)r rrrkwargss rget_pods_metricsrNsrv PNOOO : & &C#& F2#1 ,3 , 6 6v 6 66rci}|D]C} t|||||<#t$r}dt|d||<Yd}~>> from kubernetes import client, config >>> config.load_kube_config() >>> api_client = client.ApiClient() >>> >>> namespaces = ['default', 'kube-system', 'monitoring'] >>> all_metrics = get_pods_metrics_in_all_namespaces(api_client, namespaces) >>> >>> for ns, result in all_metrics.items(): ... if 'error' in result: ... print(f"{ns}: ERROR - {result['error']}") ... else: ... pod_count = len(result.get('items', [])) ... print(f"{ns}: {pod_count} pods") Error)kinderrorN)r Exceptionstr)r namespacesrresultsnses r"get_pods_metrics_in_all_namespacesr%sVG *:r>JJGBKK   QGBKKKKKK  Ns AAA)N)__doc__(kubernetes.client.api.custom_objects_apirr r rrr%rrrr(syFEEEEE%...bJ7J7J7J7Z666666r