ingest-service (Go)
Статус: пока не реализован.
Зона ответственности:
- Подписка на MQTT-топики
devices/{device_id}/telemetry. - Валидация/парсинг payload (device_id, sensor_type, value, timestamp).
- Батч-запись сырых показаний в таблицу ClickHouse
telemetry. - Публикация события «новое показание» в RabbitMQ для rule-engine-service.
Не входит в зону ответственности: интерпретация того, что означает показание датчика (пороги, действия) — это задача rule-engine-service. Этот сервис только принимает и сохраняет данные.