Архитектура
Сервис интеграции данных
Приём, валидация и нормализация входных данных.
Сервис интеграции данных
Назначение
- Загружает данные из DMS/CRM/ERP/API и файлов.
- Валидирует формат и бизнес-правила.
- Нормализует справочники и ключи.
- Публикует события для аналитики в
RabbitMQ. - Поддерживает первичную историческую загрузку при подключении нового дилера.
- Работает в суточном окне загрузки
23:00-04:00.
Хранение
- Raw слой: исходные данные
- Staging слой: очищенные и типизированные данные
Контроль качества
- Проверка полноты, дублей и диапазонов.
- Формирование отчёта качества загрузки.
- Автоматическое выявление расхождений по справочникам и автоисправление типовых ошибок.
- Передача спорных кейсов на ручной контроль и канал обратной связи с дилером.