Event Hubs Yakalama'yı keşfedin

Tamamlandı

Azure Event Hubs, event hubs'daki akış verilerini istediğiniz bir Azure Blob depolama veya Azure Data Lake Depolama hesabında otomatik olarak yakalamanıza olanak tanır ve zaman veya boyut aralığı belirtme esnekliği sunar. Yakalamayı ayarlamak hızlıdır, çalıştırmak için yönetim maliyeti yoktur ve standart katmandaki Event Hubs aktarım hızı birimleriyle veya premium katmandaki işleme birimleriyle otomatik olarak ölçeklendirilir.

Image showing capturing of Event Hubs data into Azure Storage or Azure Data Lake Storage

Event Hubs Capture, gerçek zamanlı ve toplu işlem hatlarını aynı akışta işlemenizi sağlar. Bu, zaman içinde gereksinimlerinizle büyüyen çözümler oluşturabileceğiniz anlamına gelir.

Event Hubs Yakalama nasıl çalışır?

Event Hubs, dağıtılmış bir günlüğe benzer şekilde telemetri girişi için zaman saklamaya dayanıklı bir arabellektir. Event Hubs'da ölçeklendirmenin anahtarı, bölümlenmiş tüketici modelidir. Her bölüm bağımsız bir veri kesimidir ve bağımsız olarak tüketilir. Zaman içinde bu veriler yapılandırılabilir saklama süresine göre eskir. Sonuç olarak, belirli bir olay hub'ı hiçbir zaman "çok fazla dolu" olmaz.

Event Hubs Capture, yakalanan verileri depolamak için kullanılan kendi Azure Blob depolama hesabınızı ve kapsayıcınızı veya Azure Data Lake Store hesabınızı belirtmenizi sağlar. Bu hesaplar olay hub'ınız ile aynı bölgede veya başka bir bölgede olabilir ve Event Hubs Yakalama özelliğinin esnekliğini de ekleyebilir.

Yakalanan veriler Apache Avro biçiminde yazılır: satır içi şemaya sahip zengin veri yapıları sağlayan kompakt, hızlı, ikili bir biçim. Bu biçim Hadoop ekosisteminde, Stream Analytics'te ve Azure Data Factory'de yaygın olarak kullanılır. Avro ile çalışma hakkında daha fazla bilgiye bu makalenin ilerleyen bölümlerinden ulaşabilirsiniz.

Yakalama penceresi

Event Hubs Yakalama, yakalamayı denetlemek için bir pencere ayarlamanıza olanak tanır. Bu pencere, "ilk kazanç ilkesi" olan en düşük boyut ve zaman yapılandırmasıdır ve bu da karşılaşılan ilk tetikleyicinin yakalama işlemine neden olduğu anlamına gelir. Her bölüm bağımsız olarak yakalar ve yakalama sırasında, yakalama aralığıyla karşılaşıldığı zaman için adlı tamamlanmış bir blok blobu yazar. Depolama adlandırma kuralı aşağıdaki gibidir:

{Namespace}/{EventHub}/{PartitionId}/{Year}/{Month}/{Day}/{Hour}/{Minute}/{Second}

Tarih değerlerinin sıfırlarla doldurularak eklendiğine dikkat edin; örnek bir dosya adı olabilir:

https://mystorageaccount.blob.core.windows.net/mycontainer/mynamespace/myeventhub/0/2017/12/08/03/03/17.avro

Aktarım hızı birimlerine ölçeklendirme

Event Hubs trafiği aktarım hızı birimleri tarafından denetlenmektedir. Tek bir aktarım hızı birimi, girişin saniyede 1 MB veya saniyede 1000 olay ve bu miktarın iki katı çıkışa izin verir. Standart Event Hubs 1-20 aktarım hızı birimiyle yapılandırılabilir ve kota artışı destek isteğiyle daha fazla ürün satın alabilirsiniz. Satın alınan aktarım hızı birimlerinizin ötesindeki kullanım kısıtlanır. Event Hubs Capture, aktarım hızı birimi çıkış kotalarını atlayarak ve çıkışınızı Stream Analytics veya Spark gibi diğer işleme okuyucuları için kaydederek verileri doğrudan iç Event Hubs depolama alanından kopyalar.

Yapılandırıldıktan sonra, ilk olayınızı gönderdiğinizde Event Hubs Yakalama otomatik olarak çalışır ve çalışmaya devam eder. Aşağı akış işlemenizin işlemin çalıştığını bilmesini kolaylaştırmak için Event Hubs veri olmadığında boş dosyalar yazar. Bu işlem, toplu iş işlemcilerinizi besleyebilecek öngörülebilir bir tempo ve işaretçi sağlar.