[PMA-BACKEND-004] Создать консьюмер бизнес-событий
Разработка bupar-audit-service (Backend): Реализация агрегатора сквозных событий из топика process.event.
NoteКраткая карточка задачи
- Эпик: EPIC-PMA-002
- Компонент: bupar-audit-service (Kafka Consumer)
- Статус: Готово к реализации
- Ссылка на Метод: Спецификация шинного агрегатора логов PMA
1. Бизнес-контекст и цель (Business Context)
Каждый раз, когда в домене Inventory зачисляется чек, списывается партия по FIFO или фиксируется мусор, в общую шину дублируется плоский маркер шага. Домен PMA должен асинхронно вычитывать эти маркеры и складывать в лог-архив.
Цель задачи: Реализовать слушателя топика bpds.pma.out.process.event для пакетного (Batch) сохранения аудита в Pma_db в файле pma_event_consumer.py.
2. Пользовательские истории (User Stories)
Как Архитектор событийно-ориентированной системы BPDS,
Я хочу, чтобы технические и бизнес-логи шагов стека собирались централизованно через брокер,
Чтобы разгрузить операционную базу склада от аналитических запросов выборки историй.