Skip to main content

← Observer Servisi Ana Sayfasi

Observer Servisi SSS

Genel

S: Observer akisi nerede baslatir?

A: ingest.accepted.v1 ile baslatir.


S: Observer akis bitisini ne zaman kabul eder?

A: Rule asamasi basariyla tamamlandiginda (rule.completed.v1) akis tamamlanmis sayilir.


S: Rule tarafinda trigger olmasa da basari sayilir mi?

A: Evet. No-trigger senaryosu da basarili tamamlanmadir.


Retry

S: Retry bastan mi baslar?

A: Hayir. Akis hangi stage'de kaldiysa sadece o stage'e retry atilir.


S: Max retry kac?

A: Hardcoded 3.


S: Retry bekleme modeli nedir?

A: Exponential backoff. Ornek: 5s, 15s, 45s.


S: 3 deneme de basarisiz olursa ne olur?

A: permanent_failed olarak isaretlenir ve event log'a kalici hata kaydi dusulur.


S: Device buffer ne zaman silinir?

A: Akis terminal duruma geldiginde silinir. Yani completed veya permanent_failed oldugunda Observer device_buffer:{device_id} kaydini temizler.


S: Yeni veri geldi ama eski stream hala buffer'da ise ne olur?

A: Observer stream_id cakismasini kontrol eder. Ayni stream ise duplicate kabul eder ve silmez; farkli stream ise stale timeout asildiysa eski buffer'i silip yenisini olusturur ve observer.buffer.replaced.v1 eventi yazar.


S: Neden direkt her yeni veride eski buffer silinmiyor?

A: Cihaz duplicate paket gonderebilir. incoming.stream_id == existing.stream_id durumunda kör silme veri kaybina yol acar. Bu nedenle once stream_id esitligi, sonra stale kontrolu uygulanir.


Veri ve Izlenebilirlik

S: Observer performans verisini ne zaman yazar?

A: Yalnizca lifecycle basariyla tamamlandiginda (rule success sonrasi) final performans kaydi yazilir.


S: Hangi sureler kaydedilir?

A: Tum stage process_time_ms degerleri ve end-to-end sure kaydedilir.


S: Toplam hata yuzdesi gibi akis sayaclari kaydedilir mi?

A: Evet, performans kaydina toplam deneme, toplam hata ve hata yuzdesi gibi stream akis sayaclari da yazilir.


S: Observer neden ayri consumer group kullanir?

A: Ana pipeline isleyicilerini etkilemeden bagimsiz izleme ve mudahale yapabilmek icin.