ported examples from https://github.com/tomplus/kubernetes_asyncio

Author: yliaog

examples_asyncio/in_cluster_config.py

@@ -0,0 +1,86 @@
+# Copyright 2017 The Kubernetes Authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+# Simple example to show loading config from the cluster
+
+#
+# If you get 403 errors from API server you will have to configure
+# RBAC to add necessay permissions.
+#
+# ---
+# kind: ClusterRole
+# apiVersion: rbac.authorization.k8s.io/v1
+# metadata:
+#   name: pods-list
+# rules:
+# - apiGroups: [""]
+#   resources: ["pods"]
+#   verbs: ["list"]
+# ---
+# kind: ClusterRoleBinding
+# apiVersion: rbac.authorization.k8s.io/v1
+# metadata:
+#   name: pods-list
+# subjects:
+# - kind: ServiceAccount
+#   name: default
+#   namespace: default
+# roleRef:
+#   kind: ClusterRole
+#   name: pods-list
+#   apiGroup: rbac.authorization.k8s.io
+# ---
+#
+# Doc: https://kubernetes.io/docs/reference/access-authn-authz/rbac/
+#
+# This example can be run from the image: https://hub.docker.com/r/tpimages/kubernetes_asyncio_examples/
+#
+# $ kubectl run kubernetes-asyncio-examples --image tpimages/kubernetes_asyncio_examples
+#
+
+import asyncio
+import sys
+import traceback
+
+from kubernetes_asyncio import client, config
+
+
+async def main():
+
+    while True:
+
+        try:
+
+            # it works only if this script is run by K8s as a POD
+            config.load_incluster_config()
+
+            v1 = client.CoreV1Api()
+            print("Listing pods with their IPs:")
+            ret = await v1.list_pod_for_all_namespaces()
+
+            for i in ret.items:
+                print(i.status.pod_ip, i.metadata.namespace, i.metadata.name)
+
+        except Exception:
+            traceback.print_exc(file=sys.stdout)
+
+        finally:
+            print("sleep 10s")
+            await asyncio.sleep(10)
+
+
+if __name__ == "__main__":
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(main())
+    loop.close()

examples_asyncio/list_pods.py

@@ -0,0 +1,27 @@
+import asyncio
+
+from kubernetes_asyncio import client, config
+from kubernetes_asyncio.client.api_client import ApiClient
+
+
+async def main():
+    # Configs can be set in Configuration class directly or using helper
+    # utility. If no argument provided, the config will be loaded from
+    # default location.
+    await config.load_kube_config()
+
+    # use the context manager to close http sessions automatically
+    async with ApiClient() as api:
+
+        v1 = client.CoreV1Api(api)
+        print("Listing pods with their IPs:")
+        ret = await v1.list_pod_for_all_namespaces()
+
+        for i in ret.items:
+            print(i.status.pod_ip, i.metadata.namespace, i.metadata.name)
+
+
+if __name__ == "__main__":
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(main())
+    loop.close()

examples_asyncio/patch.py

@@ -0,0 +1,109 @@
+import asyncio
+
+from kubernetes_asyncio import client, config
+from kubernetes_asyncio.client.api_client import ApiClient
+
+SERVICE_NAME = "example-service"
+SERVICE_NS = "default"
+SERVICE_SPEC = {
+    "apiVersion": "v1",
+    "kind": "Service",
+    "metadata": {
+        "labels": {"name": SERVICE_NAME},
+        "name": SERVICE_NAME,
+        "resourceversion": "v1",
+    },
+    "spec": {
+        "ports": [{"name": "port-80", "port": 80, "protocol": "TCP", "targetPort": 80}],
+        "selector": {"name": SERVICE_NAME},
+    },
+}
+
+
+async def main():
+
+    await config.load_kube_config()
+
+    async with ApiClient() as api:
+
+        v1 = client.CoreV1Api(api)
+
+        print(f"Recreate {SERVICE_NAME}...")
+        try:
+            await v1.read_namespaced_service(SERVICE_NAME, SERVICE_NS)
+            await v1.delete_namespaced_service(SERVICE_NAME, SERVICE_NS)
+        except client.exceptions.ApiException as ex:
+            if ex.status == 404:
+                pass
+
+        await v1.create_namespaced_service(SERVICE_NS, SERVICE_SPEC)
+
+        print("Patch using JSON patch - replace port-80 with port-1000")
+        patch = [
+            {
+                "op": "replace",
+                "path": "/spec/ports/0",
+                "value": {
+                    "name": "port-1000",
+                    "protocol": "TCP",
+                    "port": 1000,
+                    "targetPort": 1000,
+                },
+            }
+        ]
+        await v1.patch_namespaced_service(
+            SERVICE_NAME,
+            SERVICE_NS,
+            patch,
+            # _content_type='application/json-patch+json'  # (optional, default if patch is a list)
+        )
+
+        print(
+            "Patch using strategic merge patch - add port-2000, service will have two ports: port-1000 and port-2000"
+        )
+        patch = {
+            "spec": {
+                "ports": [
+                    {
+                        "name": "port-2000",
+                        "protocol": "TCP",
+                        "port": 2000,
+                        "targetPort": 2000,
+                    }
+                ]
+            }
+        }
+        await v1.patch_namespaced_service(
+            SERVICE_NAME,
+            SERVICE_NS,
+            patch,
+            # _content_type='application/strategic-merge-patch+json'  # (optional, default if patch is a dict)
+        )
+
+        print(
+            "Patch using merge patch - recreate list of ports, service will have only one port: port-3000"
+        )
+        patch = {
+            "spec": {
+                "ports": [
+                    {
+                        "name": "port-3000",
+                        "protocol": "TCP",
+                        "port": 3000,
+                        "targetPort": 3000,
+                    }
+                ]
+            }
+        }
+        await v1.patch_namespaced_service(
+            SERVICE_NAME,
+            SERVICE_NS,
+            patch,
+            _content_type="application/merge-patch+json",  # required to force merge patch
+        )
+
+
+if __name__ == "__main__":
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(main())
+    loop.close()