kubernetes_asyncio_list_pods_all_namespaces_quickstart.py

1import asyncio
2from library.kubernetes_asyncio import client, config
3from library.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        await v1.api_client.close()
19
20if __name__ == '__main__':
21    asyncio.run(main())