Azure Stream Analytics'ten Event Hubs çıkışı
Azure Event Hubs hizmeti, yüksek oranda ölçeklenebilir bir yayımla-abone ol olay alma işlemidir. Saniyede milyonlarca olay toplayabilir. Bir olay hub'ının çıkış olarak kullanılması, Stream Analytics işinin çıkışının başka bir akış işinin girişi olmasıdır. En büyük ileti boyutu ve toplu iş boyutu iyileştirmesi hakkında bilgi için çıktı toplu iş boyutu bölümüne bakın.
Çıkış yapılandırması
Aşağıdaki tabloda, olay hub'larından veri akışlarını çıkış olarak yapılandırmak için gereken parametreler yer alır.
| Özellik adı | Açıklama |
|---|---|
| Çıktı diğer adı | Sorgu çıkışını bu olay hub'ına yönlendirmek için sorgularda kullanılan kolay ad. |
| Olay hub’ı ad alanı | Bir dizi mesajlaşma varlığı için kapsayıcı. Yeni bir olay hub'ı oluşturduğunuzda, bir olay hub'ı ad alanı da oluşturmuştsunuz. |
| Olay hub'ı adı | Olay hub'ı çıkışınızın adı. |
| Olay hub'ı ilke adı | Olay hub'sının Yapılandır sekmesinde oluşturabileceğiniz paylaşılan erişim ilkesi. Her paylaşılan erişim ilkesinin bir adı, ayarladığınız izinleri ve erişim anahtarları vardır. |
| Olay hub'ı ilke anahtarı | Olay hub'ı ad alanına erişimin kimliğini doğrulamak için kullanılan paylaşılan erişim anahtarı. |
| Bölüm anahtarı sütunu | İsteğe bağlı. Olay hub'ı çıkışı için bölüm anahtarını içeren sütun. |
| Olay serileştirme biçimi | Çıkış verileri için serileştirme biçimi. JSON, CSV ve Avro desteklenir. |
| Encoding | CSV ve JSON için utf-8 şu anda desteklenen tek kodlama biçimidir. |
| Sınırlayıcı | Yalnızca CSV serileştirme için geçerlidir. Stream Analytics, verileri CSV biçiminde serileştirmek için bir dizi ortak sınırlayıcıyı destekler. Desteklenen değerler virgül, noktalı virgül, boşluk, sekme ve dikey çubuklardır. |
| Biçimlendir | Yalnızca JSON serileştirmesi için geçerlidir. Satır ayrılmış , çıkışın her JSON nesnesinin yeni bir satırla ayrılmasıyla biçimlendirildiğini belirtir. Çizgiyle ayrılmış'ı seçerseniz, JSON bir kerede bir nesne okunur. İçeriğin tamamı tek başına geçerli bir JSON olmayacaktır. Dizi , çıkışın bir JSON nesneleri dizisi olarak biçimlendirildiğini belirtir. |
| Özellik sütunları | İsteğe bağlı. Yük yerine giden iletinin kullanıcı özellikleri olarak eklenmesi gereken virgülle ayrılmış sütunlar. Bu özellik hakkında daha fazla bilgi çıkış için özel meta veri özellikleri bölümündedir. |
Bölümleme
Bölümleme, bölüm hizalamaya bağlı olarak değişir. Olay hub'ı çıkışının bölüm anahtarı yukarı akış (önceki) sorgu adımıyla eşit olarak hizalandığında, yazıcı sayısı olay hub'ı çıkışındaki bölüm sayısıyla aynıdır. Her yazar, olayları belirli bir bölüme göndermek için EventHubSender sınıfını kullanır. Olay hub'ı çıkışının bölüm anahtarı yukarı akış (önceki) sorgu adımıyla hizalanmadığında, yazıcı sayısı önceki adımdaki bölüm sayısıyla aynıdır. Her yazar eventhubclient içindeki SendBatchAsync sınıfını kullanarak tüm çıkış bölümlerine olay gönderir.
Çıktı toplu iş boyutu
İleti boyutu üst sınırı 256 KB veya ileti başına 1 MB'tır. Daha fazla bilgi için bkz . Event Hubs sınırları. Giriş/çıkış bölümleme hizalanmadığında, her olay tek tek EventData paketlenir ve ileti boyutu üst sınırına kadar toplu olarak gönderilir. Özel meta veri özellikleri kullanıldığında da bu durum ortaya çıkar. Giriş/çıkış bölümleme hizalandığında, birden çok olay en büyük ileti boyutuna kadar tek EventData bir örnekte paketlenir ve gönderilir.
Çıktı için özel meta veri özellikleri
Sorgu sütunlarını giden iletilerinize kullanıcı özellikleri olarak ekleyebilirsiniz. Bu sütunlar yüke girmez. Özellikler, çıkış iletisinde sözlük biçiminde bulunur. Anahtar , sütun adıdır ve değer özellikler sözlüğündeki sütun değeridir. Kayıt ve Dizi dışında tüm Stream Analytics veri türleri desteklenir.
Aşağıdaki örnekte, ve DeviceStatus alanları DeviceId meta veriye eklenir.
Aşağıdaki sorguyu kullanın:
select *, DeviceId, DeviceStatus from iotHubInputÇıkışta özellik sütunları olarak yapılandırın
DeviceId,DeviceStatus.
Service Bus Gezgini kullanılarak bir olay hub'ında incelenen beklenen çıkış iletisi özellikleri aşağıdaki görüntüdür.
Tam Olarak Bir Kez Teslim
Event Hubs çıkışında varsayılan olarak tam olarak bir kez teslim desteklenir. Girişinizden bağımsız olarak Stream Analytics, son çıkış zamanından itibaren kullanıcı tarafından başlatılan yeniden başlatmalar arasında bir Event Hubs çıkışında veri kaybı veya yineleme olmamasını garanti eder ve yinelenenlerin üretilmesini engeller. Bu, yinelenenleri kaldırma mantığını izlemek, uygulamak ve sorunlarını gidermek zorunda kalmadan akış işlem hattını büyük ölçüde basitleştirir.