[PMA-BACKEND-001] Создать SSE-стример логов

Разработка bupar-audit-service (Backend): Реализация асинхронного FastAPI эндпоинта трансляции логов из Loki.

Author

PMA Domain Lead

Published

July 13, 2026

NoteКраткая карточка задачи
  • Эпик: EPIC-PMA-001
  • Компонент: bupar-audit-service (FastAPI), Grafana Loki API
  • Статус: Готово к реализации
  • Ссылка на Метод: /api/v1/observability/stream

1. Бизнес-контекст и цель (Business Context)

Для обеспечения сквозной наблюдаемости фоновых ИИ-процессов (EasyOCR чеков, Whisper) мобильное приложение должно получать живой поток системных логов. Эндпоинт должен проксировать логи из Grafana Loki, отфильтрованные по сквозному заголовку X-Request-ID.

Цель задачи: Реализовать асинхронный метод передачи данных в формате Server-Sent Events (text/event-stream) на базе query-параметра trace_id в файле observability_stream.py.

2. Пользовательские истории (User Stories)

Как Разработчик или продвинутый пользователь, запустивший тяжелую фоновую задачу,
Я хочу видеть реактивный поток технических логов обработки моего запроса,
Чтобы контролировать ход выполнения итераций каскадного FIFO или инференса ИИ в реальном времени.


3. Шаги

1. Реализовать новый метод согласно спецификации метода /api/v1/observability/stream