Ingestion.Worker
(
)
Background worker: vybírá měření z Redis streamu (consumer group) a hromadně zapisuje do TimescaleDB hypertabulky idempotentně (ON CONFLICT DO NOTHING). Persistní polovina F10/UC10. Kód: src/Ambiquality.Ingestion.Worker.
Zápis dat
Příjem a zpracování měření
Celkový model
Aplikační vrstva
Ingestion.Worker
Zpracování měření
Ingestion.Worker
Zpráva o měření
Ingestion.Worker
Data měření
Měřicí fronta (Redis Stream)
Ingestion.Worker
Ingestion.Api
Ingestion.Worker
ingestion-worker
Ingestion.Worker