kubernetes_asyncio_list_all_pods_across_namespaces.py

1import asyncio
2from kubernetes_asyncio import client, config
3from kubernetes_asyncio.client.rest import ApiException
4
5async def main():
6    # Configs can be set in Configuration class directly or using helper utility
7    await config.load_kube_config()
8
9    v1 = client.CoreV1Api()
10    print("Listing pods with their IPs:")
11    try:
12        ret = await v1.list_pod_for_all_namespaces(watch=False)
13        for i in ret.items:
14            print(f"{i.status.pod_ip}\t{i.metadata.namespace}\t{i.metadata.name}")
15    except ApiException as e:
16        print(f"Exception when calling CoreV1Api->list_pod_for_all_namespaces: {e}")
17    finally:
18        # To close the session, it is necessary to call the close method on the client
19        await v1.api_client.close()
20
21if __name__ == '__main__':
22    asyncio.run(main())