EventBridge, yapay zeka odaklı dönemde veri entegrasyonu ve işleme için merkezi bir hub görevi gören, tamamen yönetilen ve sunucusuz bir olay verisi hizmetidir. CloudEvents 1.0 standardı üzerine inşa edilmiş olup, bileşenleri olaylar aracılığıyla birbirine bağlayarak gevşek bağlı ve ölçeklenebilir olay güdümlü mimariler (EDA) oluşturmanızı sağlar.
EventBridge; Alibaba Cloud hizmetlerinden, özel uygulamalardan ve SaaS platformlarından olayları alır; herhangi bir entegrasyon kodu yazmadan bu olayları filtreler, dönüştürür ve hedeflere iletir. Bu olay güdümlü mimari (EDA); bileşenlerin birbirini doğrudan çağırmak yerine olay yayınlama ve yanıtlama yoluyla iletişim kurduğu bir tasarım desenidir. İş yükleri arttıkça doğal olarak ölçeklenir ve mikroservis orkestrasyonu, gerçek zamanlı veri işleme ile otomatik işletim ve bakım (O&M) senaryolarında uygulanır.
Daha fazla arka plan bilgisi için bkz.:
Temel kaynaklar
EventBridge, farklı olay işleme desenleri için üç tür kaynak sağlar:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Olay veri yolu
Bir olay veri yolu, olayları alır ve yapılandırılabilir olay kurallarına göre bunları bir veya daha fazla hedefe dağıtır.
Olaylar Alibaba Cloud hizmetlerinden, özel uygulamalardan veya SaaS platformlarından gelir. Her olay kuralı bir filtre koşulu ve Function Compute, ApsaraMQ for RocketMQ veya DingTalk gibi bir veya daha fazla teslimat hedefi tanımlar. Yönlendirme sırasında, olay yapısı her hedefin beklediği formata uyacak şekilde dönüştürülür.
Temel yetenekler
İçerik filtreleme -- Olay kurallarını kullanarak olayların yük içeriğine göre eşleştirme yapın.
Olay dönüştürme -- Her hedefin beklenen formatına uyacak şekilde yönlendirme sırasında olay verilerini yeniden şekillendirin.
Çoklu hedefe teslimat -- Tek bir olayı aynı anda birden fazla aşağı akış hizmetine iletin.
Kullanım durumları
Mikroservislerin ayrıştırılması -- Bir sipariş hizmeti "Sipariş Oluşturuldu" olayını yayınlar. Envanter, lojistik ve ödül hizmetleri birbirlerine doğrudan bağımlılık olmadan bağımsız olarak abone olur.
SaaS entegrasyonu -- Salesforce'ta müşteri bilgileri değiştiğinde, güncelleme otomatik olarak dahili bir CRM sistemine senkronize edilir.
Otomatik O&M -- Cloud Monitor bir örnek hatası algılar ve bir düzeltme betiğini tetikler veya bir uyarı bildirimi gönderir.
Olay akışı
Bir olay akışı, büyük ölçekli verilerin sürekli toplanması ve gerçek zamanlı işlenmesi için yüksek aktarım hızına sahip, bir-bire (1:1) bir veri kanalı sağlar. Olay veri yolunun çoktan çoğa yönlendirmesinin aksine, olay akışı günlükler, izleme ölçümleri ve kullanıcı davranışı olayları gibi sıralı ve yüksek hacimli veriler için optimize edilmiştir.
Temel yetenekler
Yüksek aktarım hızı, düşük gecikme süresi -- Hem yazma hem de okuma işlemleri için saniyede milyonlarca işlemi (TPS) yönetin.
Tüketimi yeniden oynatma -- Geçmişteki belirli bir noktadan veri çekerek verileri yeniden işleyin.
Kullanım durumları
Gerçek zamanlı veri ambarı -- İş veritabanlarından ikili günlükleri (binlog) ve uygulama günlüklerini gerçek zamanlı olarak toplayın, Flink ile işleyin ve sonuçları bir veri ambarına yazın.
IoT verilerinin birleştirilmesi -- Çok sayıda cihazdan gelen durum verilerini birleştirin ve aşağı akış analiz sistemlerine dağıtın.
Tıklama akışı analizi -- Öneri sistemleri için web sitelerinden veya uygulamalardan kullanıcı davranışı verilerini gerçek zamanlı olarak yakalayın.
Olay deposu
Bir olay deposu, EventBridge üzerinden geçen tüm olay verilerini kalıcı olarak depolar ve bunları istediğiniz zaman SQL tabanlı sorgulamaya uygun hale getirir. Sütun bazlı ve katmanlı depolama mimarisi, sorgu performansını korurken depolama maliyetlerini düşük tutar; bu da hem uzun süreli saklama hem de gerçek zamanlı analiz için uygun olmasını sağlar.
Temel yetenekler
Anlık SQL sorguları -- Verileri ayrı bir veri ambarına taşımadan geçmiş olaylar üzerinde doğrudan standart SQL sorguları çalıştırın. Çok boyutlu toplama, filtreleme ve analizi destekler.
Düşük maliyetli lakehouse depolama -- Büyük olay veri kümelerinin uzun süreli saklanması için optimize edilmiş katmanlı depolama mimarisi.
Kullanım durumları
Kök neden analizi -- Bir sistem arızalandığında, arıza zaman penceresindeki anormal olay zincirini sorgulayarak kök nedeni belirleyin.
İş zekası raporları -- Olay akışlarından gerçek zamanlı raporlar oluşturmak için Quick BI gibi araçları bir olay deposuna bağlayın.
Olay denetimi ve uyumluluk -- Düzenleyici ve denetim gereksinimlerini karşılamak için iş olay kayıtlarını uzun süre saklayın.
Doğru kaynağı seçin
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Bu üç kaynak birlikte çalışır. Bir olay veri yolu olayları alır ve yönlendirir, bir olay akışı iki sistem arasında yüksek aktarım hızına sahip bir kanal sağlar ve bir olay deposu sorgulama ve analiz için tüm geçmiş verileri depolar.
Yapay zeka senaryoları
Yerleşik filtreleme ve dönüştürme motoru, olay verilerini bir yapay zeka modeline ulaşmadan önce ön işler; gürültüyü temizler ve özellikleri zenginleştirir. EventBridge ayrıca işlenmiş olayları makine öğrenimi platformlarına ve vektör veritabanlarına yönlendirir.
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Temel kavramlar
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Ayrıntılı tanımlar için bkz. Terimler.
Avantajlar
Faturalama
Ayrıntılar için bkz. Faturalamaya genel bakış.