Azure Stream Analytics'ten Service Bus Konuları çıkışı

  • Makale

Service Bus kuyrukları, gönderenden alıcıya bire bir iletişim yöntemi sağlar. Service Bus konuları bire çok iletişim biçimi sağlar.

Aşağıdaki tabloda, Service Bus konu çıktısı oluşturmaya yönelik özellik adları ve açıklamaları listelanmaktadır.

Özellik adı Tanım
Çıktı diğer adı Sorgu çıkışını bu Service Bus konusuna yönlendirmek için sorgularda kullanılan kolay ad.
Service Bus ad alanı Bir dizi mesajlaşma varlığı için kapsayıcı. Yeni bir olay hub'ı oluşturduğunuzda bir Service Bus ad alanı da oluşturdunuz.
Konu adı Konular, olay hub'larına ve kuyruklarına benzer mesajlaşma varlıklarıdır. Cihazlar ve hizmetlerden olay akışlarını toplamak için tasarlanmıştır. Bir konu oluşturulduğunda, belirli bir ad da verilir. Bir konu başlığına gönderilen iletiler abonelik oluşturulmadığı sürece kullanılamaz, bu nedenle konu başlığı altında bir veya daha fazla abonelik olduğundan emin olun.
Konu ilkesi adı Service Bus konusu oluşturduğunuzda, konunun Yapılandır sekmesinde paylaşılan erişim ilkeleri de oluşturabilirsiniz . Her paylaşılan erişim ilkesinin bir adı, ayarladığınız izinleri ve erişim anahtarları vardır.
Konu ilkesi anahtarı Service Bus ad alanına erişimin kimliğini doğrulamak için kullanılan paylaşılan erişim anahtarı.
Olay serileştirme biçimi Çıkış verileri için serileştirme biçimi. JSON, CSV ve Avro desteklenir.
Kodlama CSV veya JSON biçimi kullanıyorsanız bir kodlama belirtilmelidir. 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 seri hale getirme 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.
Özellik sütunları isteğ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 çıktı için özel meta veri özellikleri bölümündedir.
Sistem Özelliği sütunları isteğe bağlı. Sistem Özellikleri'nin anahtar değer çiftleri ve yük yerine giden iletiye eklenmesi gereken ilgili sütun adları.

Bölüm sayısı Service Bus SKU'sunu ve boyutunu temel alır. Bölüm anahtarı, her bölüm için benzersiz bir tamsayı değeridir.

Bölümleme

Bölümleme otomatik olarak seçilir. Bölüm sayısı Service Bus SKU'sunu ve boyutunu temel alır. Bölüm anahtarı, her bölüm için benzersiz bir tamsayı değeridir. Çıktı yazıcılarının sayısı, çıkış konu başlığındaki bölüm sayısıyla aynıdır.

Çıktı toplu iş boyutu

İleti boyutu üst sınırı, Standart katman için ileti başına 256 KB ve Premium katman için 1 MB'tır. Daha fazla bilgi için bkz . Service Bus sınırları. en iyi duruma getirmek için ileti başına tek bir olay kullanın.

Çı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.

  1. Aşağıdaki sorguyu kullanın:

    select *, DeviceId, DeviceStatus from iotHubInput

  2. Çıktıda özellik sütunları olarak yapılandırın DeviceId,DeviceStatus .

    Property columns

Aşağıdaki görüntü, Service Bus Gezgini kullanılarak EventHub'da incelenen beklenen çıkış iletisi özelliklerinin görüntüsüdür.

Event custom properties

Sistem özellikleri

Sorgu sütunlarını giden hizmet veri yolu Kuyruğunuza veya Konu iletilerinize sistem özellikleri olarak ekleyebilirsiniz. Bu sütunlar yüke girmez, bunun yerine karşılık gelen ServiceBusMessage sistem özelliği sorgu sütunu değerleriyle doldurulur. Bu sistem özellikleri desteklenir - MessageId, ContentType, Label, PartitionKey, ReplyTo, SessionId, CorrelationId, To, ForcePersistence, TimeToLive, ScheduledEnqueueTimeUtc.

Bu sütunların dize değerleri ilgili sistem özelliği değer türü olarak ayrıştırılır ve ayrıştırma hataları veri hataları olarak kabul edilir. Bu alan bir JSON nesne biçimi olarak sağlanır. Bu biçimle ilgili ayrıntılar aşağıdaki gibidir:

  • Küme ayraçları {}ile çevrili.
  • Anahtar/değer çiftleri olarak yazılır.
  • Anahtarlar ve değerler dize olmalıdır.
  • Anahtar, sistem özellik adı ve değer sorgu sütun adıdır.
  • Anahtarlar ve değerler iki nokta üst üste ile ayrılır.
  • Her anahtar/değer çifti virgülle ayrılır.

Bu, bu özelliğin nasıl kullanılacağını gösterir –

  • Sorgu: select *, column1, column2 INTO queueOutput FROM iotHubInput
  • Sistem Özelliği Sütunları: { "MessageId": "column1", "PartitionKey": "column2"}

MessageId Bu, service bus kuyruğu iletilerini 'nin değerlerine column1ve PartitionKey'in değerleriyle column2ayarlanır.

Sonraki adımlar