Event Hubs ile sunucusuz olay işlemeyi toplu olarak kaldırma ve filtreleme

Azure Event Hubs
Azure Functions
Azure Cosmos DB

Çözüm fikirleri

Bu makale bir çözüm fikridir. İçeriği olası kullanım örnekleri, alternatif hizmetler, uygulama konuları veya fiyatlandırma kılavuzu gibi daha fazla bilgiyle genişletmemizi isterseniz GitHub geri bildirimi sağlayarak bize bildirin.

Bu makalede, veritabanı depolaması için veri akışını almak ve filtrelemek için Azure Event Hubs ve Azure İşlevleri kullanan sunucusuz olay odaklı bir mimari açıklanır.

Mimari

Bu makalede açıklanan mimarideki veri akışını ve önemli işleme noktalarını gösteren diyagram

Veri akışı

  1. Olaylar Giriş Olay Hub'ına ulaşır.
  2. Olayı işlemek için Toplu İşlemeyi Kaldırma ve Azure İşlevini Filtreleme tetikleniyor. Bu adım, istenmeyen olayları filtreler ve alınan olayları Çıkış Olay Hub'ına göndermeden önce toplu işlemlerin toplu işlemlerini geri alır.
  3. Toplu işlemi kaldırma ve Azure İşlevini Filtreleme işlemi olayı başarıyla depolamazsa, olay Deadletter Event Hub 1'e gönderilir.
  4. Çıkış Olay Hub'ına gelen olaylar, Azure İşlevini Dönüştürme işlemini tetikler. Bu Azure İşlevi, olayı Azure Cosmos DB örneği için bir iletiye dönüştürür.
  5. Olay bir Azure Cosmos DB veritabanında depolanır.
  6. Dönüştürme Azure İşlevi olayı başarıyla depolamazsa, olay Deadletter Event Hub 2'ye kaydedilir.

Bileşenler

  • Event Hubs veri akışını alır. Event Hubs, yüksek performanslı veri akışı senaryoları için tasarlanmıştır.
  • Azure İşlevleri sunucusuz bir işlem seçeneğidir. Bir kod parçasının ( bir işlev) tetikleyici tarafından çağrıldığı olay odaklı bir model kullanır.
  • Azure Cosmos DB sunucusuz, tüketim tabanlı modda kullanılabilen çok modelli bir veritabanı hizmetidir. Bu senaryoda olay işleme işlevi, NoSQL için Azure Cosmos DB'yi kullanarak JSON kayıtlarını depolar.

Senaryo ayrıntıları

Bu çözüm fikri, bir veri akışını almak ve işlemek için Event Hubs ve Azure İşlevleri kullanan sunucusuz olay odaklı mimarinin bir çeşitlemesi açıklanmaktadır. Sonuçlar, toplu işlenmemiş ve filtrelendikten sonra depolama ve gelecekte gözden geçirilmeleri için bir veritabanına yazılır.

Sunucusuz olay işlemeye yönelik temel kavramlar, önemli noktalar ve yaklaşımlar hakkında daha fazla bilgi edinmek için Sunucusuz olay işleme başvuru mimarisine başvurun.

Olası kullanım örnekleri

Uçtan uca olay akışı işleme deseni uygulamaya yönelik popüler bir kullanım örneği, yüksek oranda ölçeklenebilir, olay hub'ı tarafından tetiklenen işlevlerle uygulanan toplu işleri kaldırma ve dönüştürme mantığını kullanarak saniye başına olayları almak ve işlemek için Event Hubs akış alma hizmetini içerir.

Katkıda Bulunanlar

Bu makale Microsoft tarafından yönetilir. Başlangıçta aşağıdaki katkıda bulunanlar tarafından yazılmıştır.

Asıl yazar:

Genel olmayan LinkedIn profillerini görmek için LinkedIn'de oturum açın.

Sonraki adımlar