Hızlı veri taşıma özelliğine sahip platformlar

Giriş

Platformu değiştirirken veya güncellerken bilgi aktarmak kritik bir görevdir: bakiyelerin muhasebeleştirilmesi, bahis geçmişi, bonuslar, KYC verileri ve kampanya ayarları kaybedilemez veya bozulamaz. Modern çözümler otomatik ETL boru hatları ve Change Data Capture (CDC) kullanarak iş kesintileri olmadan göçü saatler hatta dakikalar içinde tamamlar.

1. Göçlerin sınıflandırılması

1. Soğuk geçiş

Tam ihracat-ithalat, platform kapatma gerektirir.
Düşük aktivite veya planlı bakım penceresi için uygundur.
2. Sıcak geçiş

Paralel chạy ETL + CDC replikasyonu, saniyeler içinde kesilir.
24 saat trafiği olan büyük operatörler için uygundur.

2. ETL ve CDC Mimarisi

"'deniz kızı
Akış şeması LR
subgraph Kaynağı
DB1 [(Eski DB)]
Stream1 [(Eski DB CDC)]
son
Subgraph Konveyör
ETL [ETL İşi]
CDC [CDC Tüketici]
Doğrulayıcı [Veri Doğrulayıcı]
son
Subgraph Amacı
DB2 [(Yeni DB)]
son
DB1 -->tam dökümETL --> Doğrulayıcı --> DB2
Stream1 -->gerçek zamanlı değişikliklerCDC --> Doğrulayıcı --> DB2
```

ETL İşi: Bir gecede veya bir programda, tam bir tablo dökümü okur, formatları ve yükleri yeni bir şemaya dönüştürür.
CDC Tüketici: WAL günlüklerini dinler (Debezium/MySQL Binlog), gerçek zamanlı modda INSERT/UPDATE/DELETE'i atlar.
Doğrulayıcı: Temel yükten sonra ve akış çoğaltması sırasında sağlama toplamlarını ve kayıt sayaçlarını doğrular.

3. Geçiş aşamaları

1. Analiz ve haritalama (1-2 gün)

Eski ve yeni veritabanı şemalarının karşılaştırılması, alan yazışmalarının belirlenmesi (örneğin, 'player _ balance' - 'wallet. real_balance').
Tür dönüşümlerinin tanımı: satırlar - JSON, zaman damgaları, ENUM - referans tabloları.

2. Test ortamının hazırlanması (1-2 gün)

Üretim verilerinin geniş bir anlık görüntüsüne sahip bir evreleme kümesinin konuşlandırılması.
Test verileri üzerinde ETL ve CDC konektörlerini yapılandırın.

3. "soğuk yük" (2-4 saat)

Kaynak DB'den tam bir dökümü dışa aktarma - hedef DB'ye paralel içe aktarma.
Önyükleme zamanında çoğaltılmamış işlemlerin (örneğin, bir bonus motoru) devre dışı bırakılması.

4. CDC replikasyonunu başlat (sürekli)

ETL yüklemesinin başladığı andan itibaren değişiklikleri dinlemeye başlayın.
Kesme işlemi hazır olana kadar işlemlerin "kuyruğunun" birikmesi.

5. Cut-over ve trafik değiştirme (1-5 dakika)

CDC kuyruğunun geri kalanını hizalamak için uygulamaları geçici olarak durdurun.
Bağlantı dizeleri yeni bir veritabanına yeniden yapılandırılıyor.
Temel komut dosyalarının duman testleri (giriş, depozito, spin, içinde).

6. Doğrulama ve geri alma (1-2 saat)

Anahtar tablolar için sağlama toplamı denetimi - kullanıcılar, bakiyeler, işlem geçmişi.
Kritik uyumsuzluklar varsa - anlık görüntüye otomatik geri alma.

4. Test ve doğrulama

Satır sayıları ve sağlama toplamları: tablolara göre kayıt ve karma sayısının karşılaştırılması.
Alan adı testleri: örnek senaryolar - bahis, bonus ve para çekme işlemleri.
Uçtan Uca testler: Otomatik Selvi/Oyun Yazarı komut dosyaları, göçten sonra evrelemede anahtar akışı çalıştırır.

5. Arıza süresini en aza indirme

Mavi-Yeşil Veritabanı

Paralel veritabanı örnekleri...
Proxy düzeyinde Cut-over

Gelen bir bağlantı kuyruğu ile sorunsuz bir geçiş için bir proxy (PgBouncer) kullanma.
Özellik Bayrakları

Tüm hizmetleri tamamen engellememek için geçiş sırasında işlevselliğin bir kısmını devre dışı bırakmak.

6. Araçlar ve platformlar

Debezium + Kafka для CDC с MySQL/PostgreSQL.
Airbyte, Fivetran, ETL boru hatları için Talend.
Şema geçişleri ve veritabanı sürümleri için Flyway/Liquibase.
Güvenli depolama kimlik bilgileri ve rotasyon için HashiCorp Vault.

Sonuç

Hızlı veri geçişlerini destekleyen platformlar, ETL yükleme ve CDC çoğaltma, sıkı test ve doğrulama kontrollerinin bir kombinasyonu etrafında bir süreç oluşturur. Yetkili bir mimari ve otomasyon ile, kesinti süresi birkaç dakikaya indirilir ve veri kaybı veya uyumsuzluk riski sıfırdır.