File size: 1,395 Bytes
cffa613 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 | import asyncio
from fastapi import FastAPI, Request
from fastapi.responses import HTMLResponse, StreamingResponse
import json
import uvicorn
import os
app = FastAPI(title="Telemetry UI Server")
METRICS_FILE = "metrics.jsonl"
async def event_generator(request: Request):
if not os.path.exists(METRICS_FILE):
open(METRICS_FILE, "w").close()
with open(METRICS_FILE, "r") as f:
# We process from the beginning of the file to load historical chart lines rapidly,
# then we tail the file infinitely.
while True:
# Gracefully handle client connection loss
if await request.is_disconnected():
break
line = f.readline()
if not line:
await asyncio.sleep(0.1) # Wait for new content from evaluate.py
continue
# Send Server-Sent Event formatted correctly for JS consumers
yield f"data: {line}\n\n"
@app.get("/stream")
async def stream(request: Request):
return StreamingResponse(event_generator(request), media_type="text/event-stream")
@app.get("/")
async def get_index():
with open("src/ui/index.html", "r", encoding="utf-8") as f:
return HTMLResponse(content=f.read())
if __name__ == "__main__":
uvicorn.run("src.ui.dashboard:app", host="127.0.0.1", port=8001, log_level="info")
|