add utils

Author: duanhongyi

rootfs/helmbroker/celery.py

@@ -0,0 +1,15 @@
+import os
+from celery import Celery
+
+
+app = Celery(
+    'helmbroker',
+    broker=os.environ["HELMBROKER_CELERY_BROKER"],
+    backend=os.environ["HELMBROKER_CELERY_BACKEND"],
+    include=['helmbroker.tasks']
+)
+app.conf.update(result_expires=3600)
+
+
+if __name__ == '__main__':
+    app.start()

rootfs/helmbroker/helm.py

@@ -0,0 +1,6 @@
+from .celery import app
+
+
+@app.task
+def mul(x, y):
+    return x * y

rootfs/helmbroker/kubectl.py

@@ -0,0 +1,12 @@
+import yaml
+import json
+import subprocess
+
+
+def command(cmd, *args, output_type="text"):
+    output = subprocess.getoutput("%s %s" % (cmd, " ".join(args)))
+    if output_type == "yaml":
+        return yaml.load(output, Loader=yaml.Loader)
+    elif output_type == "json":
+        return json.loads(output)
+    return output

rootfs/helmbroker/tasks.py

@@ -1,2 +1,3 @@
+pyyaml==5.4.1
 gunicorn==20.1.0
 openbrokerapi==4.1.2