Add FastAPI: async Python web framework on Uvicorn (~80k⭐)

- FastAPI 0.115 + Uvicorn + uvloop + Gunicorn multi-worker
- orjson for fast JSON serialization
- Async handlers with sync SQLite via thread-local connections
- gzip compression at level 1 for /compression endpoint
- All standard endpoints: /pipeline, /baseline11, /baseline2, /json, /compression, /db, /upload

Author: BennyFranciscus

frameworks/fastapi/Dockerfile

@@ -0,0 +1,7 @@
+FROM python:3.13-slim
+WORKDIR /app
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+COPY . .
+EXPOSE 8080
+CMD ["gunicorn", "-c", "gunicorn_conf.py", "app:app"]

frameworks/fastapi/app.py

@@ -0,0 +1,156 @@
+import gzip
+import json
+import os
+import sqlite3
+import threading
+
+import orjson
+from fastapi import FastAPI, Request, Response
+
+app = FastAPI()
+
+# ── Dataset ──────────────────────────────────────────────────────────
+dataset_items = None
+dataset_path = os.environ.get("DATASET_PATH", "/data/dataset.json")
+try:
+    with open(dataset_path) as f:
+        dataset_items = json.load(f)
+except Exception:
+    pass
+
+# Large dataset for compression (pre-serialised)
+large_json_buf: bytes | None = None
+try:
+    with open("/data/dataset-large.json") as f:
+        raw = json.load(f)
+    items = []
+    for d in raw:
+        item = dict(d)
+        item["total"] = round(d["price"] * d["quantity"] * 100) / 100
+        items.append(item)
+    large_json_buf = orjson.dumps({"items": items, "count": len(items)})
+except Exception:
+    pass
+
+# ── SQLite (thread-local, sync — runs in threadpool via run_in_executor) ──
+db_available = os.path.exists("/data/benchmark.db")
+DB_QUERY = (
+    "SELECT id, name, category, price, quantity, active, tags, rating_score, rating_count "
+    "FROM items WHERE price BETWEEN ? AND ? LIMIT 50"
+)
+_local = threading.local()
+
+
+def _get_db() -> sqlite3.Connection:
+    conn = getattr(_local, "conn", None)
+    if conn is None:
+        conn = sqlite3.connect("/data/benchmark.db", uri=True)
+        conn.execute("PRAGMA mmap_size=268435456")
+        conn.row_factory = sqlite3.Row
+        _local.conn = conn
+    return conn
+
+
+# ── Helpers ──────────────────────────────────────────────────────────
+def _text(body: str | bytes, status: int = 200) -> Response:
+    return Response(
+        content=body,
+        status_code=status,
+        media_type="text/plain",
+        headers={"Server": "fastapi"},
+    )
+
+
+def _json_resp(body: bytes, status: int = 200, extra_headers: dict | None = None) -> Response:
+    headers = {"Server": "fastapi"}
+    if extra_headers:
+        headers.update(extra_headers)
+    return Response(content=body, status_code=status, media_type="application/json", headers=headers)
+
+
+# ── Routes ───────────────────────────────────────────────────────────
+@app.get("/pipeline")
+async def pipeline():
+    return _text(b"ok")
+
+
+@app.api_route("/baseline11", methods=["GET", "POST"])
+async def baseline11(request: Request):
+    total = 0
+    for v in request.query_params.values():
+        try:
+            total += int(v)
+        except ValueError:
+            pass
+    if request.method == "POST":
+        body = await request.body()
+        if body:
+            try:
+                total += int(body.strip())
+            except ValueError:
+                pass
+    return _text(str(total))
+
+
+@app.get("/baseline2")
+async def baseline2(request: Request):
+    total = 0
+    for v in request.query_params.values():
+        try:
+            total += int(v)
+        except ValueError:
+            pass
+    return _text(str(total))
+
+
+@app.get("/json")
+async def json_endpoint():
+    if dataset_items is None:
+        return _text("No dataset", 500)
+    items = []
+    for d in dataset_items:
+        item = dict(d)
+        item["total"] = round(d["price"] * d["quantity"] * 100) / 100
+        items.append(item)
+    body = orjson.dumps({"items": items, "count": len(items)})
+    return _json_resp(body)
+
+
+@app.get("/compression")
+async def compression_endpoint():
+    if large_json_buf is None:
+        return _text("No dataset", 500)
+    compressed = gzip.compress(large_json_buf, compresslevel=1)
+    return _json_resp(compressed, extra_headers={"Content-Encoding": "gzip"})
+
+
+@app.get("/db")
+async def db_endpoint(request: Request):
+    if not db_available:
+        return _json_resp(b'{"items":[],"count":0}')
+    min_val = float(request.query_params.get("min", 10))
+    max_val = float(request.query_params.get("max", 50))
+    conn = _get_db()
+    rows = conn.execute(DB_QUERY, (min_val, max_val)).fetchall()
+    items = []
+    for r in rows:
+        items.append(
+            {
+                "id": r["id"],
+                "name": r["name"],
+                "category": r["category"],
+                "price": r["price"],
+                "quantity": r["quantity"],
+                "active": bool(r["active"]),
+                "tags": json.loads(r["tags"]),
+                "rating": {"score": r["rating_score"], "count": r["rating_count"]},
+            }
+        )
+    body = orjson.dumps({"items": items, "count": len(items)})
+    return _json_resp(body)
+
+
+@app.post("/upload")
+async def upload_endpoint(request: Request):
+    data = await request.body()
+    return _text(str(len(data)))

frameworks/fastapi/gunicorn_conf.py

@@ -0,0 +1,6 @@
+import os
+
+bind = "0.0.0.0:8080"
+workers = len(os.sched_getaffinity(0)) * 2
+worker_class = "uvicorn.workers.UvicornWorker"
+keepalive = 120

frameworks/fastapi/meta.json

@@ -0,0 +1,19 @@
+{
+  "display_name": "FastAPI",
+  "language": "Python",
+  "type": "framework",
+  "engine": "uvicorn",
+  "description": "FastAPI async web framework on Uvicorn (uvloop), multi-worker via gunicorn.",
+  "repo": "https://github.com/fastapi/fastapi",
+  "enabled": true,
+  "tests": [
+    "baseline",
+    "pipelined",
+    "noisy",
+    "limited-conn",
+    "json",
+    "upload",
+    "compression",
+    "mixed"
+  ]
+}

frameworks/fastapi/requirements.txt

@@ -0,0 +1,6 @@
+fastapi==0.115.12
+uvicorn[standard]==0.34.0
+gunicorn==23.0.0
+uvloop==0.21.0
+aiosqlite==0.21.0
+orjson==3.10.15