⚠️ Arşiv Notu: Bu sayfa aktif akışın ana referansı değildir; geçmiş tasarım/bağlam için korunur.

İşlem Akışı (Ingestion → Synthesis → Window)

Bu bölüm Cınga veri hattını uçtan uca anlatır. Akışın amacı, yazım hızını korurken analitik doğruluğu kaybetmemektir.

İlk adımda payload kabul edilir ve streams kaydı oluşturulur. Bu noktada stream_id tüm zincirin teknik referansı olur. Ardından kalibrasyon ve sentez kural snapshot’ları çözülür; worker önce Redis’e bakar, gerekirse DB fallback yapar. Redis’te sırasıyla cal:{device_id}:{version} ve synth_rules:{device_id}:{version} anahtarları kullanılır.

Konfigürasyon çözüldükten sonra ham ölçümlerde yalnızca CT etkisindeki değişkenlere cihaz CT oranı uygulanır; ardından aktif kalibrasyon kuralı olan değişkenlerde kalibrasyon çalıştırılır ve sonuç enerji segment tablolara yazılır.

Ham yazım tamamlandığında sistem stream_id ve device_id bilgisini Redis kuyruğuna bırakır. Böylece ingestion kritik yolu kapanır ve sentez hesapları asenkron katmana devredilir.

Sentez adımında synth_worker Redis kuyruğundaki kaydı tüketir, ilgili cihazın kural snapshot’ını çözer (cihaza özel, yoksa global fallback), ardından stream-anlık türev metrikleri ve bileşen skorlarını üretir. Bu çıktının kalıcı tablo modeli bir sonraki aşamada netleştirilecektir. Sonrasında window_worker devreye girer; sabit ve kayan pencereleri günceller, kalite ve dağılım/trend alanlarını energy_windows tablosuna yazar.

Bütün zincir idempotent tasarlanır. Aynı stream tekrar işlense bile tekilleştirme anahtarları sayesinde kayıtlar çoğalmaz, yalnızca güvenli güncelleme yapılır. Hata durumunda retry/backoff uygulanır; kalıcı başarısızlık DLQ’ya düşer.

Bu akış sayesinde Cınga mimarisi hem sahadan yoğun veri alımını kaldırır hem de pompa sağlığına yönelik analitik katmanı sürdürülebilir şekilde üretir.