added wrappers and updated knative functions

Signed-off-by: Abhishek Kumar <abhishek22512@gmail.com>

Author: octonawish-akcodes

benchmarks/wrappers/knative/python/func.py

@@ -0,0 +1,42 @@
+import logging
+import datetime
+from flask import jsonify
+from parliament import Context
+from function import handler
+
+
+def main(context: Context):
+    logging.getLogger().setLevel(logging.INFO)
+    begin = datetime.datetime.now()
+
+    try:
+        # Extract JSON data from the request
+        event = context.request.json
+        print(f"Received event: {event}")
+
+        # Pass the extracted JSON data to the handler function
+        ret = handler(event)
+        end = datetime.datetime.now()
+        logging.info(f"Function result: {ret}")
+        results_time = (end - begin) / datetime.timedelta(microseconds=1)
+
+        response = {
+            "begin": begin.strftime("%s.%f"),
+            "end": end.strftime("%s.%f"),
+            "results_time": results_time,
+            "result": ret,
+        }
+
+        return jsonify(response), 200
+
+    except Exception as e:
+        end = datetime.datetime.now()
+        results_time = (end - begin) / datetime.timedelta(microseconds=1)
+        logging.error(f"Error - invocation failed! Reason: {e}")
+        response = {
+            "begin": begin.strftime("%s.%f"),
+            "end": end.strftime("%s.%f"),
+            "results_time": results_time,
+            "result": f"Error - invocation failed! Reason: {e}",
+        }
+        return jsonify(response), 500

benchmarks/wrappers/knative/python/storage.py

@@ -249,7 +249,7 @@
         "username": "docker_user",
         "deployment": {
           "files": [
-            "handler.py",
+            "func.py",
             "storage.py"
           ],
           "packages": {
@@ -269,8 +269,8 @@
         "username": "docker_user",
         "deployment": {
           "files": [
-            "handler.js",
-            "storage.js"
+            "",
+            ""
           ],
           "packages": []
         }

config/systems.json

@@ -101,7 +101,9 @@ def deserialize(config: dict, cache: Cache, handlers: LoggingHandlers) -> Resour
         # Check for new config
         if "storage" in config:
             ret._storage = MinioConfig.deserialize(config["storage"])
-            ret.logging.info("Using user-provided configuration of storage for Knative.")
+            ret.logging.info(
+                "Using user-provided configuration of storage for Knative."
+            )
 
             # check if there has been an update
             if not (
@@ -122,21 +124,26 @@ def deserialize(config: dict, cache: Cache, handlers: LoggingHandlers) -> Resour
             and "resources" in cached_config
             and "storage" in cached_config["resources"]
         ):
-            ret._storage = MinioConfig.deserialize(cached_config["resources"]["storage"])
+            ret._storage = MinioConfig.deserialize(
+                cached_config["resources"]["storage"]
+            )
             ret.logging.info("Using cached configuration of storage for Knative.")
 
         return ret
 
     def update_cache(self, cache: Cache):
         super().update_cache(cache)
         cache.update_config(
-            val=self.docker_registry, keys=["knative", "resources", "docker", "registry"]
+            val=self.docker_registry,
+            keys=["knative", "resources", "docker", "registry"],
         )
         cache.update_config(
-            val=self.docker_username, keys=["knative", "resources", "docker", "username"]
+            val=self.docker_username,
+            keys=["knative", "resources", "docker", "username"],
         )
         cache.update_config(
-            val=self.docker_password, keys=["knative", "resources", "docker", "password"]
+            val=self.docker_password,
+            keys=["knative", "resources", "docker", "password"],
         )
         if self._storage:
             self._storage.update_cache(["knative", "resources", "storage"], cache)

sebs/knative/config.py

@@ -7,6 +7,7 @@
 from sebs.faas.function import Function, FunctionConfig, Runtime
 from sebs.storage.config import MinioConfig
 
+
 @dataclass
 class KnativeFunctionConfig(FunctionConfig):
     docker_image: str = ""
@@ -31,9 +32,14 @@ def from_benchmark(benchmark: Benchmark) -> KnativeFunctionConfig:
             benchmark, KnativeFunctionConfig
         )
 
+
 class KnativeFunction(Function):
     def __init__(
-        self, name: str, benchmark: str, code_package_hash: str, cfg: KnativeFunctionConfig
+        self,
+        name: str,
+        benchmark: str,
+        code_package_hash: str,
+        cfg: KnativeFunctionConfig,
     ):
         super().__init__(benchmark, name, code_package_hash, cfg)
 
@@ -55,12 +61,17 @@ def deserialize(cached_config: dict) -> KnativeFunction:
 
         cfg = KnativeFunctionConfig.deserialize(cached_config["config"])
         ret = KnativeFunction(
-            cached_config["name"], cached_config["benchmark"], cached_config["hash"], cfg
+            cached_config["name"],
+            cached_config["benchmark"],
+            cached_config["hash"],
+            cfg,
         )
         for trigger in cached_config["triggers"]:
             trigger_type = cast(
                 Trigger,
-                {"Library": KnativeLibraryTrigger, "HTTP": KnativeHTTPTrigger}.get(trigger["type"]),
+                {"Library": KnativeLibraryTrigger, "HTTP": KnativeHTTPTrigger}.get(
+                    trigger["type"]
+                ),
             )
             assert trigger_type, "Unknown trigger type {}".format(trigger["type"])
             ret.add_trigger(trigger_type.deserialize(trigger))