Metriklerin Ötesinde Observability: Sistem Hikaye Anlatıcılığı Sanatı

// Metriklerimizin bize gösterdiği
interface GelenekselMetrikler {
  cpu: "ortalama %40";
  bellek: "6GB/8GB";
  responseTime: "200ms p50";
  hataOrani: "%0.1";
  // Mükemmel görünüyor, değil mi?
}

// Distributed trace'in ortaya çıkardığı
interface GercekHikaye {
  kullaniciYolculugu: "checkout_denemesi";
  toplamSure: "8.3 saniye"; // Kullanıcı 5 saniye sonra vazgeçti
  spanSayisi: 247; // ~15 olmalıydı
  kritikYol: {
    servis: "oneri-servisi",
    operasyon: "ilgili_urunleri_getir",
    cagrilar: 47, // İşte suçlu
    toplamZaman: "6.8 saniye"
  };
  isEtkisi: {
    terkedilmisSepetler: 1247,
    kayipGelir: "$186,000/saat"
  };
}

import { trace, context, SpanStatusCode } from '@opentelemetry/api';
import { BusinessContext } from './business-metrics';

class CheckoutService {
  private tracer = trace.getTracer('checkout-service', '1.0.0');
  
  async processCheckout(userId: string, cart: CartData): Promise<CheckoutResult> {
    // Teknik detaylarla değil, iş bağlamıyla başla
    const span = this.tracer.startSpan('kullanici.checkout.deneme', {
      attributes: {
        'kullanici.id': userId,
        'kullanici.seviye': await this.getUserTier(userId),
        'is.sepet_degeri': cart.totalValue,
        'is.gelir_etkisi': cart.totalValue,
        'yolculuk.adim': 'checkout_basladi',
        'yolculuk.giris_noktasi': cart.referrer
      }
    });
    
    // Context'i servis sınırları boyunca yay
    return context.with(trace.setSpan(context.active(), span), async () => {
      try {
        // Her adım hikayeye eklenir
        span.addEvent('envanter.dogrulama.basladi', {
          kontrol_edilecek_urunler: cart.items.length
        });
        
        const inventory = await this.validateInventory(cart);
        
        if (!inventory.allAvailable) {
          // Checkout'un NEDEN başarısız olduğunu söyler
          span.setAttributes({
            'hata.nedeni': 'envanter_yok',
            'hata.urunler': inventory.unavailableItems.join(','),
            'is.etki': 'checkout_terkedildi'
          });
          span.setStatus({ 
            code: SpanStatusCode.ERROR, 
            message: 'Envanter kontrolü başarısız' 
          });
          return { success: false, reason: 'stokta_yok' };
        }
        
        // Hikayeyi oluşturmaya devam et...
        span.addEvent('odeme.isleme.basladi');
        const payment = await this.processPayment(cart, userId);
        
        span.setAttributes({
          'yolculuk.tamamlandi': true,
          'is.siparis_degeri': payment.amount,
          'yolculuk.toplam_sure_ms': Date.now() - span.startTime
        });
        
        return { success: true, orderId: payment.orderId };
        
      } catch (error) {
        // Başarısızlık hikayesini yakala
        span.recordException(error);
        span.setAttributes({
          'hata.asama': this.getCurrentStage(),
          'hata.kurtarma_denendi': true,
          'is.etki': 'gelir_kaybi'
        });
        throw error;
      } finally {
        span.end();
      }
    });
  }
}

interface IsEtkisiAnalizcisi {
  async traceEtkisiniAnalizeEt(traceId: string): Promise<EtkiRaporu> {
    const trace = await this.getTrace(traceId);
    const isKonteksti = this.extractBusinessContext(trace);
    
    return {
      // Teknik hikaye
      teknikAnlati: {
        girisNoktasi: trace.rootSpan.service,
        hataNoktalsi: this.findFailureSpan(trace),
        cascadeEtkisi: this.analyzeCascade(trace),
        performansDarbogazi: this.findSlowestPath(trace)
      },
      
      // İş hikayesi
      isAnlatisi: {
        kullaniciAmaci: isKonteksti.yolculukTuru, // "satin_alma", "gezinme", vb.
        riskAltindakiDeger: isKonteksti.sepetDegeri || isKonteksti.abonelikDegeri,
        kullaniciSegmenti: isKonteksti.kullaniciSeviyesi,
        donusumAsamasi: this.getConversionStage(trace),
        alternatifYollar: this.findAlternativeJourneys(isKonteksti)
      },
      
      // Birleşik hikaye
      etki: {
        anlikGelirKaybi: this.calculateImmediateLoss(isKonteksti),
        tahminKaybRiski: this.predictChurnImpact(trace, isKonteksti),
        markaHasarSkoru: this.assessBrandImpact(trace),
        kurtarmaAksiyonlari: this.generateRecoveryPlan(trace, isKonteksti)
      }
    };
  }
}

class AITraceAnalizcisi {
  async hataPatterniBul(traces: DistributedTrace[]): Promise<Analiz> {
    const prompt = `
      E-ticaret platformumuzdan bu distributed trace'leri analiz et:
      ${JSON.stringify(traces, null, 2)}
      
      Kontekst:
      - Sistem peak'te dakikada 10K sipariş işliyor
      - Sipariş işlemede 12 mikroservis var
      - Son deployment: envanter servisi v2.3.1 (3 saat önce)
      
      Bul:
      1. Başarısız işlemlerdeki ortak pattern'ler
      2. Dış olaylarla zamansal korelasyonlar
      3. Servis bağımlılık anomalileri
      4. Güven skoru ile kök neden hipotezi
      
      Hem teknik hem de iş pattern'lerini düşün.
    `;
    
    const analiz = await this.llm.analyze(prompt);
    
    // AI tamamen kaçırdığımız bir şey buldu
    return {
      pattern: "Hatalar cache invalidation'dan tam 47 saniye sonra oluşuyor",
      kokNeden: "Cache yenileme ve envanter güncellemeleri arasında race condition",
      guven: 0.94,
      kanit: [
        "Tüm hatalarda 47±2 saniye önce cache_invalidated event'i var",
        "Envanter servisi v2.3.1 async cache refresh getirdi",
        "Load balancer retry timeout 45 saniye"
      ],
      isEtkisi: "Sepet güncellemeleri sırasında yüksek değerli müşterileri etkiliyor",
      onerilenCozum: "Cache refresh operasyonlarında distributed lock uygula"
    };
  }
}

class HikayeOdakliAlerting {
  async alertDegerlendir(anomali: TraceAnomaly): Promise<AlertKarari> {
    // Sadece teknik metriklere alert verme
    if (!anomali.hasBusinessContext()) {
      return { alertVer: false, neden: "İş etkisi tespit edilmedi" };
    }
    
    // Tam hikayeyi oluştur
    const hikaye = await this.hikayeOlustur(anomali);
    
    // Sadece hikaye önemliyse alert ver
    const etkiSkoru = this.etkiSkoruHesapla({
      etkilenenKullanicilar: hikaye.kullaniciSayisi,
      riskAltindakiGelir: hikaye.potansiyelKayip,
      musteriSeviyesi: hikaye.birincilKullaniciSegmenti,
      gunSaati: hikaye.isSaatleriMi,
      benzerOlaylar: await this.benzerHikayelriBul(hikaye)
    });
    
    if (etkiSkoru < this.alertEsigi) {
      // Logla, ama kimseyi uyandırma
      await this.sonrakiAnalizIcinLogla(hikaye);
      return { alertVer: false, neden: "Etki eşiğinin altında" };
    }
    
    // Tüm hikayeyi anlatan bir alert oluştur
    return {
      alertVer: true,
      kanal: this.etkiIcinKanalBul(etkiSkoru),
      mesaj: this.anlatisalAlertOlustur(hikaye),
      onerilenAksiyonlar: await this.playbookOlustur(hikaye),
      otoRemediasyon: this.otoRemediasyonYapilabilirMi(hikaye)
    };
  }
  
  private anlatisalAlertOlustur(hikaye: OlayHikayesi): string {
    return `
      📖 Olay Hikayesi:
      
      Ne oluyor: ${hikaye.ozet}
      Kim etkileniyor: ${hikaye.etkilenenKullanicilar} kullanıcı (${hikaye.kullaniciSegmentleri})
      İş etkisi: Saatte $${hikaye.gelirEtkisi} potansiyel kayıp
      
      Bozulan yolculuk:
      ${hikaye.bozulanYolculuk.map(adim => `→ ${adim}`).join('\n')}
      
      Kök neden (%${hikaye.guven} güvenle): ${hikaye.kokNeden}
      
      Benzer olay: ${hikaye.oncekiOlay?.ozet || 'Benzer olay bulunamadı'}
      
      Önerilen aksiyonlar:
      ${hikaye.onerilenAksiyonlar.map((aksiyon, i) => `${i+1}. ${aksiyon}`).join('\n')}
    `;
  }
}

interface ObservabilityMaliyetleri {
  altyapi: {
    openTelemetryCollectors: 800,  // 3 instance, yüksek bellek
    dagitikIzleme: 1200,           // 30 günlük saklama ile Jaeger
    aiAnaliz: 400,                 // Pattern analizi için GPT-4 API çağrıları
    korelasyonPlatformu: 2500,     // Grafana üzerine custom yapı
    olayOtomasyonu: 600            // Workflow otomasyon araçları
  },
  
  gizliMaliyetler: {
    muhendisZamani: "DevOps kapasitesinin %20'si",
    depoBuyumesi: "Günde 50GB trace verisi",
    networkOverhead: "%5-10 artan trafik",
    cpuOverhead: "Instrument edilmiş servis başına %2-5"
  },
  
  faydalar: {
    mttrAzaltma: "2.5 saat → 18 dakika",
    olayOnleme: "%60 daha az production sorunu",
    nodbetYasamKalitesi: "%70 daha az yanlış alert",
    gelirKoruma: "Yıllık $200K+ tasarruf"
  }
}

# Her yerde değil, buradan başla
oncelik_instrumentasyon:
  faz_1:
    - kullanici_kayit_akisi
    - checkout_sureci
    - arama_satin_alma
  
  faz_2:
    - admin_operasyonlari
    - arka_plan_isleri
    - ucuncu_parti_entegrasyonlar
  
  faz_3:
    - dahili_araclar
    - raporlama_sistemleri
    - geri_kalan_her_sey

class AkillirSampling {
  sampleOraniAl(span: Span): number {
    // Hataları ve yüksek değerli işlemleri her zaman örnekle
    if (span.status === 'ERROR') return 1.0;
    if (span.attributes['kullanici.seviye'] === 'premium') return 1.0;
    if (span.attributes['is.deger'] > 1000) return 1.0;
    
    // İş saatlerine göre örnekle
    const saat = new Date().getHours();
    if (saat >= 9 && saat <= 17) return 0.1;  // İş saatlerinde %10
    
    // Sessiz dönemlerde minimal örnekleme
    return 0.01; // Gece %1
  }
}

interface EkipEgitimPlani {
  hafta1: "Dağıtık izleme temelleri",
  hafta2: "OpenTelemetry instrumentation workshop",
  hafta3: "Trace hikayelerini okuma ve yorumlama",
  hafta4: "Trace'leri iş metrikleri ile ilişkilendirme",
  hafta5: "AI destekli olay analizi",
  hafta6: "Hikaye anlatan custom dashboard'lar oluşturma",
  
  surekli: {
    aylikIncelemeler: "İlginç olayları birlikte analiz etme",
    dokumantasyonGunleri: "Herkes bir observability kılavuzu yazıyor",
    rotasyonProgrami: "Herkes bir hafta incident command yapıyor",
    bilgiPaylasimi: "Haftalık 'trace dedektifi' oturumları"
  }
}

interface TahminselObservability {
  pattern: "Cache invalidation artışı tespit edildi",
  tahmin: "Sipariş işleme ~47 saniye içinde başarısız olacak",
  guven: 0.89,
  onleyiciAksiyon: "Envanter servisini proaktif olarak ölçekle",
  isEtkisi: "$45K terkedilmiş sepeti önle"
}