SeBS Cloudflare Compatibility

.mypy.ini

@@ -3,6 +3,9 @@
 [mypy-docker]
 ignore_missing_imports = True
 
+[mypy-docker.*]
+ignore_missing_imports = True
+
 [mypy-tzlocal]
 ignore_missing_imports = True
 

benchmarks/000.microbenchmarks/040.server-reply/config.json

@@ -1,6 +1,6 @@
 {
   "timeout": 120,
   "memory": 128,
-  "languages": ["python", "nodejs"],
+  "languages": ["python"],
   "modules": []
 }

benchmarks/100.webapps/110.dynamic-html/config.json

@@ -1,6 +1,22 @@
 {
   "timeout": 10,
   "memory": 128,
-  "languages": ["python", "nodejs", "java"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    {
+      "language": "nodejs",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    "java"
+  ],
   "modules": []
 }

benchmarks/100.webapps/120.uploader/config.json

@@ -1,6 +1,21 @@
 {
   "timeout": 60,
   "memory": 128,
-  "languages": ["python", "nodejs"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": {"workers": "cloudflare", "containers": "default"}
+      }
+    },
+    {
+      "language": "nodejs",
+      "variants": {
+        "default": "default",
+        "cloudflare": {"workers": "cloudflare", "containers": "default"}
+      }
+    }
+  ],
   "modules": ["storage"]
 }

benchmarks/100.webapps/120.uploader/nodejs/cloudflare/function.js

@@ -0,0 +1,35 @@
+// Copyright 2020-2025 ETH Zurich and the SeBS authors. All rights reserved.
+// Cloudflare Workers differ from the default Node.js version: Workers require
+// ES module syntax (no CommonJS `require`) and do not ship the `request` npm
+// package, so we use the platform-native `fetch` API and buffer the response
+// into /tmp instead of piping a stream.
+import * as fs from 'node:fs';
+import * as path from 'node:path';
+import { storage } from './storage';
+
+let storage_handler = new storage();
+
+export const handler = async function(event) {
+  let bucket = event.bucket.bucket;
+  let output_prefix = event.bucket.output;
+  let url = event.object.url;
+  let upload_key = path.basename(url);
+  let download_path = path.join('/tmp', upload_key);
+
+  const response = await fetch(url, {
+    headers: {
+      'User-Agent': 'SeBS/1.2 (https://github.com/spcl/serverless-benchmarks) SeBS Benchmark Suite/1.2'
+    }
+  });
+  const buffer = await response.arrayBuffer();
+  fs.writeFileSync(download_path, Buffer.from(buffer));
+
+  let [keyName, uploadPromise] = storage_handler.upload(
+    bucket,
+    path.join(output_prefix, upload_key),
+    download_path
+  );
+  await uploadPromise;
+
+  return {result: {bucket: bucket, url: url, key: keyName}};
+};

benchmarks/100.webapps/120.uploader/python/cloudflare/function.py

@@ -0,0 +1,61 @@
+# Copyright 2020-2025 ETH Zurich and the SeBS authors. All rights reserved.
+# Cloudflare Workers differ from the default Python version: the Workers
+# Python runtime is Pyodide-based and does not support `urllib.request`, so
+# we download via Pyodide's async `pyfetch` and wrap it with `run_sync` to
+# keep the synchronous handler signature.
+
+import datetime
+import os
+
+from pyodide.ffi import run_sync
+from pyodide.http import pyfetch
+
+from . import storage
+client = storage.storage.get_instance()
+
+SEBS_USER_AGENT = "SeBS/1.2 (https://github.com/spcl/serverless-benchmarks) SeBS Benchmark Suite/1.2"
+
+async def do_request(url, download_path):
+    headers = {'User-Agent': SEBS_USER_AGENT}
+
+    res = await pyfetch(url, headers=headers)
+    bs = await res.bytes()
+
+    with open(download_path, 'wb') as f:
+        f.write(bs)
+
+def handler(event):
+
+    bucket = event.get('bucket').get('bucket')
+    output_prefix = event.get('bucket').get('output')
+    url = event.get('object').get('url')
+    name = os.path.basename(url)
+    download_path = '/tmp/{}'.format(name)
+
+    process_begin = datetime.datetime.now()
+
+    run_sync(do_request(url, download_path))
+
+    size = os.path.getsize(download_path)
+    process_end = datetime.datetime.now()
+
+    upload_begin = datetime.datetime.now()
+    key_name = client.upload(bucket, os.path.join(output_prefix, name), download_path)
+    upload_end = datetime.datetime.now()
+
+    process_time = (process_end - process_begin) / datetime.timedelta(microseconds=1)
+    upload_time = (upload_end - upload_begin) / datetime.timedelta(microseconds=1)
+    return {
+            'result': {
+                'bucket': bucket,
+                'url': url,
+                'key': key_name
+            },
+            'measurement': {
+                'download_time': 0,
+                'download_size': 0,
+                'upload_time': upload_time,
+                'upload_size': size,
+                'compute_time': process_time
+            }
+    }

benchmarks/100.webapps/130.crud-api/config.json

@@ -2,8 +2,20 @@
   "timeout": 30,
   "memory": 128,
   "languages": [
-    "python",
-    "nodejs"
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    {
+      "language": "nodejs",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    }
   ],
   "modules": [
     "nosql"

benchmarks/200.multimedia/210.thumbnailer/config.json

@@ -1,7 +1,23 @@
 {
   "timeout": 60,
   "memory": 256,
-  "languages": ["python", "nodejs", "cpp"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    {
+      "language": "nodejs",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    "cpp"
+  ],
   "modules": ["storage"],
   "cpp_dependencies": ["sdk", "opencv", "libjpeg-turbo", "boost"]
 }

benchmarks/200.multimedia/220.video-processing/config.json

@@ -1,6 +1,14 @@
 {
   "timeout": 60,
   "memory": 512,
-  "languages": ["python"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    }
+  ],
   "modules": ["storage"]
 }

benchmarks/300.utilities/311.compression/config.json

@@ -1,6 +1,22 @@
 {
   "timeout": 60,
   "memory": 256,
-  "languages": ["python", "nodejs"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    {
+      "language": "nodejs",
+      "variants": {
+        "default": "default",
+        "cloudflare": {"workers": "default", "containers": "default"}
+      }
+    }
+  ],
   "modules": ["storage"]
 }
+

benchmarks/400.inference/411.image-recognition/config.json

@@ -1,7 +1,16 @@
 {
   "timeout": 60,
   "memory": 768,
-  "languages": ["python", "cpp"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": {"workers": "default", "containers": "cloudflare"}
+      }
+    },
+    "cpp"
+  ],
   "modules": ["storage"],
   "cpp_dependencies": ["sdk", "torch", "opencv"]
 }

benchmarks/400.inference/411.image-recognition/python/cloudflare/requirements.txt.3.11

@@ -0,0 +1,6 @@
+# Copyright 2020-2025 ETH Zurich and the SeBS authors. All rights reserved.
+pillow==10.3.0
+torch==2.0.0
+torchvision==0.15.1
+# prevent installing numpy 2.0
+numpy==1.24.0

benchmarks/400.inference/411.image-recognition/python/cloudflare/requirements.txt.3.12

@@ -0,0 +1,6 @@
+# Copyright 2020-2025 ETH Zurich and the SeBS authors. All rights reserved.
+pillow==10.3.0
+torch==2.0.0
+torchvision==0.15.1
+# prevent installing numpy 2.0
+numpy==1.24.0

benchmarks/500.scientific/501.graph-pagerank/config.json

@@ -1,7 +1,16 @@
 {
   "timeout": 120,
   "memory": 512,
-  "languages": ["python", "cpp"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    "cpp"
+  ],
   "modules": [],
   "cpp_dependencies": ["igraph"]
 }

benchmarks/500.scientific/502.graph-mst/config.json

@@ -1,6 +1,14 @@
 {
   "timeout": 120,
   "memory": 512,
-  "languages": ["python"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    }
+  ],
   "modules": []
 }

benchmarks/500.scientific/503.graph-bfs/config.json

@@ -1,7 +1,16 @@
 {
   "timeout": 120,
   "memory": 512,
-  "languages": ["python", "cpp"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    },
+    "cpp"
+  ],
   "modules": [],
   "cpp_dependencies": ["igraph"]
 }

benchmarks/500.scientific/504.dna-visualisation/config.json

@@ -1,6 +1,14 @@
 {
   "timeout": 60,
   "memory": 2048,
-  "languages": ["python"],
+  "languages": [
+    {
+      "language": "python",
+      "variants": {
+        "default": "default",
+        "cloudflare": "default"
+      }
+    }
+  ],
   "modules": ["storage"]
 }