Share via

Service Bus-témakörök kimenete az Azure Stream Analyticsből

  • Cikk

A Service Bus-üzenetsorok egy-az-egyhez kommunikációs módszert biztosítanak a feladótól a fogadóig. A Service Bus-témakörök a kommunikáció egy-a-többhöz formáját biztosítják.

Az alábbi táblázat felsorolja a Service Bus-témakör kimenetének létrehozásához használt tulajdonságneveket és azok leírását.

Tulajdonság neve Leírás
Kimeneti alias A lekérdezésekben használt rövid név, amellyel a lekérdezés kimenetét erre a Service Bus-témakörre irányíthatja.
Service Bus-névtér Üzenetkezelési entitások egy készletének tárolója. Amikor létrehozott egy új eseményközpontot, létrehozott egy Service Bus-névteret is.
Témakör neve A témakörök az eseményközpontokhoz és üzenetsorokhoz hasonló üzenetkezelési entitások. Úgy tervezték, hogy eseménystreameket gyűjtsön az eszközökről és szolgáltatásokról. Amikor létrehoz egy témakört, az adott nevet is kap. A témakörnek küldött üzenetek csak előfizetés létrehozása után érhetők el, ezért győződjön meg arról, hogy a témakör egy vagy több előfizetéssel rendelkezik.
Témakörházirend neve Service Bus-témakör létrehozásakor megosztott hozzáférési szabályzatokat is létrehozhat a témakör Konfigurálás lapján. Minden megosztott hozzáférési szabályzat rendelkezik névvel, beállított engedélyekkel és hozzáférési kulcsokkal.
Témakörházirend-kulcs A Service Bus-névtérhez való hozzáférés hitelesítéséhez használt közös hozzáférési kulcs.
Eseményszerializációs formátum A kimeneti adatok szerializálási formátuma. A JSON, a CSV és az Avro támogatott.
Kódolás HA CSV- vagy JSON-formátumot használ, kódolást kell megadni. Jelenleg az UTF-8 az egyetlen támogatott kódolási formátum.
Elválasztókarakter Csak CSV-szerializálásra alkalmazható. A Stream Analytics számos gyakori elválasztójelet támogat az adatok CSV formátumban történő szerializálásához. A támogatott értékek a következők: vessző, pontosvessző, szóköz, lap és függőleges sáv.
Tulajdonságoszlopok Opcionális. Vesszővel tagolt oszlopok, amelyeket a hasznos adat helyett a kimenő üzenet felhasználói tulajdonságaiként kell csatolni. Erről a funkcióról további információt a kimenet egyéni metaadat-tulajdonságai című szakaszban talál.
Rendszertulajdonság-oszlopok Opcionális. A rendszertulajdonságok kulcsértékpárjai és a megfelelő oszlopnevek, amelyeket a hasznos adat helyett a kimenő üzenethez kell csatolni.

A partíciók száma a Service Bus termékváltozatán és méretén alapul. A partíciókulcs az egyes partíciók egyedi egész számértéke.

Particionálás

A particionálás automatikusan ki lesz választva. A partíciók száma a Service Bus termékváltozatán és méretén alapul. A partíciókulcs az egyes partíciók egyedi egész számértéke. A kimeneti írók száma megegyezik a kimeneti témakör partícióinak számával.

Kimeneti köteg mérete

Az üzenetek maximális mérete üzenetenként 256 KB a Standard szint és 1 MB a Prémium szinten. További információ: Service Bus-korlátok. Az optimalizáláshoz üzenetenként egyetlen eseményt használjon.

A kimenet egyéni metaadat-tulajdonságai

A lekérdezésoszlopokat felhasználói tulajdonságokként csatolhatja a kimenő üzenetekhez. Ezek az oszlopok nem kerülnek a hasznos adatok közé. A tulajdonságok szótár formájában jelennek meg a kimeneti üzenetben. A kulcs az oszlop neve, az érték pedig a tulajdonságszótár oszlopértéke. A Record és a Array kivételével minden Stream Analytics-adattípus támogatott.

Az alábbi példában a mezőket DeviceIdDeviceStatus a rendszer hozzáadja a metaadatokhoz.

  1. Használja a következő lekérdezést:

    select *, DeviceId, DeviceStatus from iotHubInput

  2. Konfigurálja DeviceId,DeviceStatus tulajdonságoszlopként a kimenetben.

    Property columns

Az alábbi kép az EventHubon a Service Bus Explorerrel megvizsgált várható kimeneti üzenettulajdonságokat ábrázolja.

Event custom properties

Rendszertulajdonságok

A lekérdezési oszlopokat rendszertulajdonságokként csatolhatja a kimenő szolgáltatásbusz üzenetsorához vagy témakörüzeneteihez. Ezek az oszlopok nem kerülnek a hasznos adatokba, hanem a megfelelő ServiceBusMessage rendszertulajdonság a lekérdezés oszlopértékeivel van feltöltve. Ezek a rendszertulajdonságok támogatottak – MessageId, ContentType, Label, PartitionKey, ReplyTo, SessionId, CorrelationId, To, ForcePersistence, TimeToLive, ScheduledEnqueueTimeUtc.

Ezeknek az oszlopoknak a sztringértékeit a rendszer a megfelelő rendszertulajdonság-értéktípusként elemzi, és az elemzési hibák adathibákként lesznek kezelve. Ez a mező JSON-objektumformátumként van megadva. A formátum részletei a következők:

  • Kapcsos kapcsos zárójelek {}veszik körül.
  • Kulcs-érték párokban íródott.
  • A kulcsoknak és értékeknek sztringeknek kell lenniük.
  • A kulcs a rendszertulajdonság neve, az érték pedig a lekérdezés oszlopának neve.
  • A kulcsokat és az értékeket kettőspont választja el egymástól.
  • Minden kulcs-érték pár vesszővel van elválasztva.

Ez bemutatja, hogyan használhatja ezt a tulajdonságot –

  • Lekérdezés: select *, column1, column2 INTO queueOutput FROM iotHubInput
  • Rendszertulajdonság-oszlopok: { "MessageId": "column1", "PartitionKey": "column2"}

Ez beállítja a MessageId service bus üzenetsor üzeneteit az 's értékekkel, column1a PartitionKey pedig 's értékekkel column2van beállítva.

Következő lépések