inecs
5e0e5ee1da
- Порт хоста по умолчанию 8080 (Chrome ERR_UNSAFE_PORT на 6000); compose, setup, config, README.
- Дашборд: одна hero-карточка, прогресс создания, POST /jobs/{id}/cancel, JobView progress_*.
- job_store: отмена и прогресс (thread-safe); cluster_lifecycle этапы и откат.
- Навигация: стили nav-pill; Swagger/ReDoc/Health через window.open.
- main.py: TemplateResponse(request, …) для Starlette.
- Документация: README, app/docs (api_routes, README); Makefile ps; .gitignore clusters.
82 lines
3.2 KiB
Python
82 lines
3.2 KiB
Python
"""Веб-интерфейс и REST API для управления локальными кластерами kind.
|
|
|
|
В контейнере uvicorn слушает порт 6000; на хост публикация по умолчанию 8080 (``KIND_K8S_WEB_PORT``), т.к. 6000 на хосте блокируется Chrome (ERR_UNSAFE_PORT).
|
|
|
|
Запуск в контейнере: ``python3 -m uvicorn main:app --host 0.0.0.0 --port 6000`` из каталога ``/opt/kind-k8s/app``
|
|
или через ``make docker up`` / ``make podman up``.
|
|
|
|
Автор: Сергей Антропов
|
|
Сайт: https://devops.org.ru
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import logging
|
|
import os
|
|
from contextlib import asynccontextmanager
|
|
from pathlib import Path
|
|
|
|
from fastapi import FastAPI, Request
|
|
from fastapi.responses import HTMLResponse, RedirectResponse
|
|
from fastapi.staticfiles import StaticFiles
|
|
from fastapi.templating import Jinja2Templates
|
|
|
|
from api.v1.router import api_router
|
|
from core.config import get_settings
|
|
|
|
_BASE = Path(__file__).resolve().parent
|
|
logger = logging.getLogger("kind_k8s.web")
|
|
|
|
|
|
def _configure_logging() -> None:
|
|
"""Единая настройка логов для uvicorn и модулей kind-k8s."""
|
|
if logging.root.handlers:
|
|
return
|
|
level = logging.DEBUG if os.environ.get("KIND_K8S_DEBUG", "").strip().lower() in ("1", "true", "yes", "да") else logging.INFO
|
|
logging.basicConfig(level=level, format="%(levelname)s %(name)s: %(message)s")
|
|
logger.info("Логирование инициализировано, уровень=%s", logging.getLevelName(level))
|
|
|
|
|
|
@asynccontextmanager
|
|
async def lifespan(app: FastAPI):
|
|
"""Старт и остановка приложения."""
|
|
_configure_logging()
|
|
settings = get_settings()
|
|
logger.info("Запуск FastAPI «%s»", settings.app_title)
|
|
yield
|
|
logger.info("Остановка FastAPI")
|
|
|
|
|
|
settings = get_settings()
|
|
app = FastAPI(title=settings.app_title, lifespan=lifespan)
|
|
app.include_router(api_router, prefix="/api/v1")
|
|
|
|
_templates_dir = _BASE / "templates"
|
|
_static_dir = _BASE / "static"
|
|
if _static_dir.is_dir():
|
|
app.mount("/static", StaticFiles(directory=str(_static_dir)), name="static")
|
|
|
|
templates = Jinja2Templates(directory=str(_templates_dir))
|
|
|
|
|
|
@app.get("/", response_class=HTMLResponse, summary="Веб-интерфейс")
|
|
async def dashboard(request: Request) -> HTMLResponse:
|
|
"""Главная страница с формой создания и таблицей кластеров."""
|
|
if not _templates_dir.is_dir():
|
|
return HTMLResponse(
|
|
content="<p>Шаблоны не найдены. Ожидается каталог app/templates/</p>",
|
|
status_code=500,
|
|
)
|
|
# Starlette ≥0.37: первым аргументом обязателен Request (иначе dict уйдёт в get_template → unhashable type).
|
|
return templates.TemplateResponse(
|
|
request,
|
|
"dashboard.html",
|
|
{"app_title": settings.app_title},
|
|
)
|
|
|
|
|
|
@app.get("/ui", include_in_schema=False)
|
|
async def ui_redirect() -> RedirectResponse:
|
|
"""Удобный алиас на корень UI."""
|
|
return RedirectResponse(url="/", status_code=307)
|