Výstup témat služby Service Bus z Azure Stream Analytics

  • Článek

Fronty služby Service Bus poskytují metodu komunikace 1:1 od odesílatele po příjemce. Témata služby Service Bus poskytují formu komunikace 1:N.

Následující tabulka uvádí názvy vlastností a jejich popisy pro vytvoření výstupu tématu služby Service Bus.

Název vlastnosti Popis
Alias pro výstup Popisný název použitý v dotazech k nasměrování výstupu dotazu do tohoto tématu služby Service Bus.
Obor názvů služby Service Bus Kontejner pro sadu entit zasílání zpráv. Při vytváření nového centra událostí jste také vytvořili obor názvů služby Service Bus.
Název tématu Témata jsou entity zasílání zpráv, podobně jako centra událostí a fronty. Jsou navržené tak, aby shromažďovali streamy událostí ze zařízení a služeb. Když se téma vytvoří, dá se mu také konkrétní název. Zprávy odeslané do tématu nejsou k dispozici, pokud se nevytvořilo předplatné, proto zajistěte, aby v tématu bylo jedno nebo více odběrů.
Název zásady tématu Při vytváření tématu služby Service Bus můžete také vytvořit zásady sdíleného přístupu na kartě Konfigurace tématu. Každá zásada sdíleného přístupu má název, oprávnění, která jste nastavili, a přístupové klíče.
Klíč zásad tématu Sdílený přístupový klíč, který slouží k ověření přístupu k oboru názvů služby Service Bus.
Formát serializace události Formát serializace pro výstupní data. Podporují se JSON, CSV a Avro.
Kódování Pokud používáte formát CSV nebo JSON, musí být zadáno kódování. UTF-8 je v tuto chvíli jediným podporovaným formátem kódování.
Delimiter Platí pouze pro serializaci CSV. Stream Analytics podporuje řadu běžných oddělovačů pro serializaci dat ve formátu CSV. Podporované hodnoty jsou čárka, středník, mezera, tabulátor a svislý pruh.
Sloupce vlastností Nepovinné. Sloupce oddělené čárkami, které musí být připojeny jako vlastnosti uživatele odchozí zprávy místo datové části. Další informace o této funkci najdete v části Vlastní vlastnosti metadat pro výstup.
Sloupce systémových vlastností Nepovinné. Páry klíčových hodnot vlastností systému a odpovídající názvy sloupců, které musí být připojeny k odchozí zprávě místo datové části.

Počet oddílů vychází ze skladové položky a velikosti služby Service Bus. Klíč oddílu je jedinečná celočíselná hodnota pro každý oddíl.

dělení na části

Dělení se vybere automaticky. Počet oddílů vychází ze skladové položky a velikosti služby Service Bus. Klíč oddílu je jedinečná celočíselná hodnota pro každý oddíl. Počet výstupních zapisovačů je stejný jako počet oddílů ve výstupním tématu.

Velikost dávky výstupu

Maximální velikost zprávy je 256 kB na zprávu pro úroveň Standard a 1 MB pro úroveň Premium. Další informace najdete v tématu Omezení služby Service Bus. K optimalizaci použijte jednu událost na zprávu.

Vlastní vlastnosti metadat pro výstup

Sloupce dotazů můžete připojit jako vlastnosti uživatele k odchozím zprávům. Tyto sloupce se do datové části nepřecházejí. Vlastnosti jsou přítomné ve formě slovníku ve výstupní zprávě. Klíč je název sloupce a hodnota je hodnota sloupce ve slovníku vlastností. Všechny datové typy Stream Analytics jsou podporovány s výjimkou záznamů a polí.

V následujícím příkladu se pole DeviceIdDeviceStatus přidají do metadat.

  1. Spusťte následující dotaz:

    select *, DeviceId, DeviceStatus from iotHubInput

  2. Ve výstupu nakonfigurujte DeviceId,DeviceStatus jako sloupce vlastností.

    Property columns

Následující obrázek je očekávaných vlastností výstupní zprávy kontrolovaných v EventHubu pomocí Service Bus Exploreru.

Event custom properties

Systémové vlastnosti

Sloupce dotazů můžete připojit jako systémové vlastnosti ke zprávě fronty nebo tématu odchozí sběrnice. Tyto sloupce nepřecházejí do datové části, místo toho se odpovídající systémová vlastnost ServiceBusMessage naplní hodnotami sloupce dotazu. Tyto systémové vlastnosti jsou podporovány - MessageId, ContentType, Label, PartitionKey, ReplyTo, SessionId, CorrelationId, To, ForcePersistence, TimeToLive, ScheduledEnqueueTimeUtc.

Řetězcové hodnoty těchto sloupců se analyzují jako odpovídající typ hodnoty systémové vlastnosti a všechny chyby analýzy se považují za chyby dat. Toto pole je k dispozici jako formát objektu JSON. Podrobnosti o tomto formátu jsou následující:

  • Obklopený složenými závorkami {}.
  • Zapsané ve dvojicích klíč/hodnota
  • Klíče a hodnoty musí být řetězce.
  • Klíč je název systémové vlastnosti a hodnota je název sloupce dotazu.
  • Klíče a hodnoty jsou oddělené dvojtečku.
  • Každý pár klíč/hodnota je oddělený čárkou.

Ukazuje, jak tuto vlastnost používat –

  • Dotazu: select *, column1, column2 INTO queueOutput FROM iotHubInput
  • Sloupce systémových vlastností: { "MessageId": "column1", "PartitionKey": "column2"}

Tím se nastaví MessageId zprávy fronty služby Service Bus s column1hodnotami a PartitionKey se nastaví s column2hodnotami.

Další kroky