Přidání vlastního koncového bodu nebo vlastního zdroje aplikace do eventstreamu

Pokud chcete připojit vlastní aplikaci k eventstreamu, můžete přidat vlastní koncový bod nebo vlastní aplikaci jako zdroj. Události v reálném čase pak můžete odesílat do streamu událostí z vlastní aplikace s koncovým bodem připojení vystaveným na vlastním koncovém bodu nebo vlastní aplikaci. Díky protokolu Apache Kafka, který je k dispozici jako možnost pro vlastní koncové body nebo vlastní aplikace, můžete také odesílat události v reálném čase pomocí protokolu Apache Kafka.

Tento článek ukazuje, jak přidat vlastní zdroj koncového bodu nebo vlastní zdroj aplikace do eventstreamu ve streamech událostí Microsoft Fabric.

Poznámka:

Vylepšené funkce jsou ve výchozím nastavení povolené při vytváření eventstreamů. Pokud máte streamy událostí vytvořené pomocí standardních funkcí, budou tyto streamy událostí dál fungovat. Pořád je můžete upravovat a používat jako obvykle. Doporučujeme vytvořit nový stream událostí, který nahradí standardní streamy událostí, abyste mohli využívat další možnosti a výhody rozšířených streamů událostí.

Požadavky

Než začnete, ujistěte se, že máte přístup k pracovnímu prostoru, ve kterém se nachází váš eventstream. Pracovní prostor musí být v kapacitě Fabric nebo ve zkušebním režimu.

• K úpravě streamu událostí pro přidání vlastního zdroje koncového bodu se vyžadují oprávnění přispěvatele nebo vyšší úrovně.
• Pokud chcete pro připojení aplikace použít ověřování Entra ID , potřebujete oprávnění člena nebo vyšší.

Pokud používáte ověřování Entra ID, musíte se také ujistit, že spravovaná identita vlastního koncového bodu má požadovaná oprávnění. Provedete to tak, že nakonfigurujete potřebná nastavení na portálu pro správu:

1. Vyberte Nastavení (ikona ozubeného kola) v pravém horním rohu.

2. V části Zásady správného řízení a přehledy vyberte Portál pro správu.

   

3. Aktivujte následující nastavení tenanta, abyste služebnímu principálovi udělili přístup k rozhraním Fabric API pro vytváření pracovních prostorů, připojení nebo kanálů nasazení.

   • Na stránce Nastavení klienta v části Nastavení pro vývojáře rozbalte možnost Hlavní služba může použít rozhraní FABRIC API.
   • Přepněte na Povoleno.
   • Aplikovat na celou organizaci.
   • Vyberte a použijte.

   

4. Povolte tuto možnost pro přístup ke všem ostatním API (povoleno ve výchozím nastavení pro nové nájemce):

   • Na stránce Nastavení tenanta rozbalte možnost Povolit instančním objektům vytvářet a používat profily .
   • Přepněte na Povoleno.
   • Aplikovat na celou organizaci.
   • Vyberte a použijte.

Poznámka:

Eventstream může podporovat až 11 kombinovaných zdrojů a cílů pouze při použití následujících typů:

• Zdroj: Vlastní koncový bod.
• Cíle: Vlastní koncový bod a Eventhouse s přímým příjmem dat

Žádné zdroje nebo cíle , které nejsou zahrnuté v seznamu výše a cíle nepřipojené k výchozímu datovému proudu, se do tohoto limitu nezapočítávají.

Přidejte vlastní data koncového bodu jako zdroj

1. Pokud chcete přidat vlastní zdroj koncového bodu, na stránce Začínáme vyberte Použít vlastní koncový bod. Pokud už máte publikovaný eventstream a chcete přidat vlastní data koncového bodu jako zdroj, přepněte do režimu úprav. Na pásu karet vyberte Přidat zdroj>vlastní koncový bod.

   

2. V dialogovém okně Vlastní koncový bod zadejte název vlastního zdroje v části Název zdroje a pak vyberte Přidat.

   

3. Po vytvoření vlastního zdroje koncového bodu se přidá do eventstreamu na plátně v režimu úprav. Pokud chcete implementovat nově přidaná data z vlastního zdroje aplikace, vyberte Publikovat.

   

Poznámka:

Eventstream může podporovat až 11 kombinovaných zdrojů a cílů pouze při použití následujících typů:

• Zdroj: Vlastní koncový bod.
• Cíle: Vlastní koncový bod a Eventhouse s přímým příjmem dat

Žádné zdroje nebo cíle , které nejsou zahrnuté v seznamu výše a cíle nepřipojené k výchozímu datovému proudu, se do tohoto limitu nezapočítávají.

Získejte podrobnosti o koncovém bodu v podokně Podrobností

Po vytvoření vlastního zdroje koncového bodu jsou její data k dispozici pro vizualizaci v živém zobrazení.

Podokno Podrobnosti obsahuje tři karty protokolu: Centrum událostí, AMQP a Kafka. Každá karta protokolu má dvě stránky: Základní a Ověřování pomocí klíče SAS. Tyto stránky nabízejí podrobnosti o koncovém bodu s odpovídajícím protokolem pro připojení.

Základní informace ukazují název, typ a stav vašeho vlastního koncového bodu.

Stránka ověřování pomocí klíče SAS poskytuje informace o klíčích připojení a také odkaz na ukázkový kód s vloženými odpovídajícími klíči, které můžete použít k streamování událostí do streamu událostí. Informace na stránce Klíče se liší podle protokolu.

Centrum událostí

Stránka Ověřování SAS klíče na kartě Event Hub obsahuje informace související s připojovacím řetězcem Event Hub. Mezi informace patří název centra událostí, název sdíleného přístupového klíče, primární klíč, sekundární klíč, připojovací řetězec primární klíč, sekundární klíč připojovacího řetězce.

Formát centra událostí je výchozí pro připojovací řetězec a funguje se sadou Azure Event Hubs SDK. Tento formát umožňuje připojení k eventstreamu prostřednictvím protokolu Event Hubs.

Následující příklad ukazuje, jak připojovací řetězec vypadá ve formátu centra událostí:

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

Pokud vyberete tlačítko Zobrazit ukázkový kód, zobrazí se kód Java připravený k použití, který obsahuje požadované informace o klíčích připojení v centru událostí. Zkopírujte ho a vložte ho do aplikace pro použití.

Rozšířený protokol řízení front zpráv (AMQP)

Formát AMQP je kompatibilní s protokolem AMQP 1.0, což je standardní protokol zasílání zpráv, který podporuje interoperabilitu mezi různými platformami a jazyky. Tento formát můžete použít k připojení k eventstreamu pomocí protokolu AMQP.

Když vyberete Tlačítko Zobrazit ukázkový kód , zobrazí se kód Java připravený k použití s informacemi o klíči připojení ve formátu AMQP.

Kafka

Formát Kafka je kompatibilní s protokolem Apache Kafka, což je oblíbená platforma pro distribuované streamování, která podporuje zpracování dat s vysokou propustností a nízkou latencí. K připojení k eventstreamu a streamování událostí můžete použít ověřovací informace o klíči SAS pro formát protokolu Kafka.

Když vyberete tlačítko Zobrazit vzorový kód , zobrazí se kód Java připravený k použití, včetně potřebných klíčů připojení ve formátu Kafka. Zkopírujte ho pro své použití.

Pro jasný návod k používání vlastního koncového bodu s protokolem Kafka se podívejte do tohoto tutoriálu. Poskytuje podrobné kroky pro streamování a využívání událostí pomocí vlastního koncového bodu s protokolem Kafka.

Poznámka:

• Můžete zvolit formát protokolu, který vyhovuje potřebám a předvolbám vaší aplikace, a pak zkopírujte a vložte připojovací řetězec do aplikace. Můžete také odkazovat nebo kopírovat vzorový kód, který ukazuje, jak odesílat nebo přijímat události pomocí různých protokolů.

• Pokud chcete zobrazení ukázkového kódu opustit, vyberte Skrýt vzorový kód.

Související obsah

Seznam podporovaných zdrojů najdete v tématu Přidání zdroje událostí v eventstreamu.

Požadavky

• Přístup k pracovnímu prostoru v režimu licence kapacity Fabric nebo ve zkušebním režimu licence s oprávněními přispěvatele nebo vyššími.
• Pokud nemáte stream událostí, vytvořte stream událostí.

Přidání vlastní aplikace jako zdroje

Pokud chcete připojit vlastní aplikaci k eventstreamu, můžete přidat vlastní zdroj aplikace. Potom odešlete data do eventstreamu z vlastní aplikace s koncovým bodem připojení vystaveným ve vlastní aplikaci.

Přidání vlastního zdroje aplikace:

1. Na pásu karet vyberte Nový zdroj nebo znaménko plus (+) na hlavním plátně editoru a pak vyberte Vlastní aplikace.

2. V podokně Vlastní aplikace zadejte název zdroje vlastní aplikace a pak vyberte Přidat.

   

Získejte podrobnosti o koncovém bodu v podokně s podrobnostmi pro odeslání událostí.

Po úspěšném vytvoření vlastní aplikace jako zdroje můžete zobrazit informace v podokně Podrobností .

Podokno Podrobnosti obsahuje tři karty protokolu: Centrum událostí, AMQP a Kafka. Každá karta protokolu obsahuje tři stránky: Základní, Ověřování pomocí klíče SAS a Ověřování entra ID. Tyto stránky poskytují informace o koncovém bodu specifické pro vybraný protokol.

• Na stránce Basic se zobrazuje název, typ a stav vašeho vlastního koncového bodu.

• Ověřování pomocí klíče SAS a ověřování entra ID jsou dvě podporované metody ověřování pro připojení k vaší aplikaci:
  • Ověřování pomocí klíče SAS poskytuje informace potřebné k vytváření a využívání dat eventstreamu pomocí klíčů sdíleného přístupového podpisu (SAS).
  • Ověřování Entra ID umožňuje instančnímu objektu zabezpečení (například uživateli nebo instančnímu objektu) využívat data eventstreamu pomocí ověřování Microsoft Entra ID.

Postup použití ověřování Entra ID najdete v tématu Povolení ověřování ID Entra pro aplikaci v eventstreamu.
Následující část popisuje, jak se připojit k vlastnímu koncovému bodu pomocí SAS klíče.

Centrum událostí

Stránka Klíče na kartě Centra událostí obsahuje informace o připojovacím řetězci centra událostí. Informace zahrnují název centra událostí, název sdíleného přístupového klíče, primární klíč a primární klíč připojovacího řetězce.

Formát centra událostí je výchozí pro připojovací řetězec a funguje se sadou Azure Event Hubs SDK. Tento formát umožňuje připojení k eventstreamu prostřednictvím protokolu Event Hubs.

Následující příklad ukazuje, jak připojovací řetězec vypadá ve formátu centra událostí:

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

Výběrem tlačítka Zobrazit ukázkový kód na stránce centra událostí získáte kód připravený k použití, který obsahuje požadované informace o klíčích připojení v centru událostí. Jednoduše ho zkopírujte a vložte do aplikace pro použití.

Kafka

Formát Kafka je kompatibilní s protokolem Apache Kafka, což je oblíbená platforma pro distribuované streamování, která podporuje zpracování dat s vysokou propustností a nízkou latencí. K připojení k eventstreamu a streamování událostí můžete použít informace o klíčích a vzorovém kódu pro formát protokolu Kafka.

Výběrem tlačítka Zobrazit ukázkový kód na stránce Kafka získáte připravený kód, včetně potřebných klíčů připojení ve formátu Kafka. Jednoduše ho zkopírujte pro své použití.

AMQP

Formát AMQP je kompatibilní s protokolem AMQP 1.0, což je standardní protokol zasílání zpráv, který podporuje interoperabilitu mezi různými platformami a jazyky. Tento formát můžete použít k připojení k eventstreamu pomocí protokolu AMQP.

Výběrem tlačítka Zobrazit ukázkový kód na stránce AMQP získáte kód připravený k použití s informacemi o klíči připojení ve formátu AMQP.

Můžete zvolit formát protokolu, který vyhovuje potřebám a předvolbám vaší aplikace, a pak zkopírujte a vložte připojovací řetězec do aplikace. Můžete také odkazovat nebo kopírovat vzorový kód na stránce Vzorový kód , který ukazuje, jak odesílat nebo přijímat události pomocí různých protokolů.

Související obsah

Informace o přidání dalších zdrojů do eventstreamu najdete v následujících článcích:

• Azure Event Hubs
• Azure IoT Hub
• Ukázková data