Dela via

Lägga till en anpassad slutpunkt eller anpassad appkälla i en händelseström

Om du vill ansluta ditt eget program till en händelseström kan du lägga till en anpassad slutpunkt eller en anpassad app som källa. Sedan kan du skicka realtidshändelser till händelseströmmen från ditt eget program via den anslutningspunkt som är exponerad på den anpassade slutpunkten eller appen. Med Apache Kafka-protokollet tillgängligt som ett alternativ för anpassade slutpunkter eller anpassade appar kan du också skicka realtidshändelser med hjälp av Apache Kafka-protokollet.

Den här artikeln visar hur du lägger till en anpassad slutpunktskälla eller en anpassad appkälla till en händelseström i Microsoft Fabric-händelseströmmar.

Förutsättningar

Innan du börjar kontrollerar du att du har åtkomst till arbetsytan där din eventstream finns. Arbetsytan måste vara i Fabric capacity eller Trial läge.

  • Deltagare eller högre behörigheter krävs för att redigera händelseströmmen för att lägga till en anpassad slutpunktskälla .
  • Om du vill använda Entra-ID-autentisering för att ansluta ditt program behöver du medlems - eller högre behörigheter.

Om du använder Entra-ID-autentisering måste du också se till att den hanterade identiteten för den anpassade slutpunkten har de behörigheter som krävs. Det gör du genom att konfigurera de nödvändiga inställningarna i administratörsportalen:

  1. Välj Inställningar (kugghjulsikon) i det övre högra hörnet.

  2. Välj Administratörsportal under avsnittet Styrning och insikter .

    Skärmbild som visar valet av administratörsportallänk i avsnittet Styrning och insikter.

  3. Aktivera följande klientinställning för att ge tjänstehuvudmännens åtkomst till Fabric-API:er för att skapa arbetsytor, anslutningar eller distributionspipelines.

    • På sidan Inställningar för klientorganisation går du till avsnittet Inställningar för utvecklare och expanderar alternativet tjänstehuvudnamn kan använda Fabric API.
    • Växla till Aktiverad.
    • Gäller för hela organisationen.
    • Välj Använd.

    Skärmbild som visar utvecklarinställningarna.

  4. Aktivera det här alternativet för att komma åt alla andra API:er (aktiverade som standard för nya klienter):

    • På sidan Klientinställningar utökar du alternativet Tillåt tjänstehuvuden att skapa och använda profiler.
    • Växla till Aktiverad.
    • Gäller för hela organisationen.
    • Välj Använd.

Anteckning

En händelseström kan endast stödja upp till 11 kombinerade källor och mål när du använder följande typer:

  • Källa: Anpassad slutpunkt.
  • Mål: Anpassad slutpunkt och Eventhouse med direkt inmatning.

Alla källor eller mål som inte ingår i listan ovan och mål som inte läggs till i standardströmmen räknas inte mot den här gränsen.

Lägga till anpassade slutpunktsdata som källa

  1. Om du vill lägga till en anpassad slutpunktskälla går du till sidan Komma igång och väljer Använd anpassad slutpunkt. Om du redan har en publicerad händelseström och vill lägga till anpassade slutpunktsdata som källa växlar du till redigeringsläge. I menyfliksområdet väljer du Lägg till anpassad källslutpunkt>.

    Skärmbild av alternativet att använda en anpassad slutpunkt.

  2. I dialogrutan Anpassad slutpunkt anger du ett namn för den anpassade källan under Källnamn och väljer sedan Lägg till.

    Skärmbild av dialogrutan för att lägga till en anpassad slutpunkt.

  3. När du har skapat den anpassade slutpunktskällan läggs den till i din eventstream på arbetsytan i redigeringsläge. Om du vill implementera nyligen tillagda data från den anpassade appkällan väljer du Publicera.

    Skärmbild som visar händelseströmmen i redigeringsläge med knappen Publicera markerad.

Anteckning

En händelseström kan endast stödja upp till 11 kombinerade källor och mål när du använder följande typer:

  • Källa: Anpassad slutpunkt.
  • Mål: Anpassad slutpunkt och Eventhouse med direkt inmatning.

Alla källor eller mål som inte ingår i listan ovan och mål som inte läggs till i standardströmmen räknas inte mot den här gränsen.

Lägga till anpassade slutpunktsdata som källa

  1. Om du vill lägga till en anpassad slutpunktskälla går du till sidan Komma igång och väljer Använd anpassad slutpunkt. Om du redan har en publicerad händelseström och vill lägga till anpassade slutpunktsdata som källa växlar du till redigeringsläge. I menyfliksområdet väljer du Lägg till anpassad källslutpunkt>.

    Skärmbild av alternativet att använda en anpassad slutpunkt.

  2. På sidan Lägg till källa väljer du Aktivera för schemaassociation och väljer sedan Lägg till.

    Skärmbild av anpassad slutpunktskälla med ett alternativ för att associera scheman.

  3. Välj Associera händelseschema i menyfliksområdet för att associera med ett nytt schema eller ett befintligt schema från ett schemaregister.

    Skärmbild av eventstream-redigeraren med knappen Associera händelseschema i menyfliksområdet som valts.

  4. Om du vill använda ett befintligt schema väljer du Välj från händelseschemaregistret och följer dessa steg:

    1. I fönstret Associera ett händelseschema väljer du ett schema från schemaregistret. Du ser händelsedataschemat i den högra rutan.

    2. Välj Välj för att associera händelseschemat med den anpassade slutpunkten.

      Skärmbild av fönstret Associera händelseschema med ett schema valt från schemaregistret.

    3. I Eventstream-redigeraren väljer du panelen eventstream . I den nedre rutan växlar du till fliken Associera schema . Bekräfta att schemat är associerat med händelseströmmen.

      Skärmbild av Eventstream-redigeraren med eventstream markerat och fliken Associerat schema markerat.

  5. Använd något av följande alternativ för att skapa ett schema.

    • Om du har en JSON-schemafil väljer du Ladda upp för att ladda upp filen. En exempelfil finns i avsnittet Exempelschemafil .

      Skärmbild som visar uppladdningsalternativet för att skapa ett schema.

    • Börja skapa ett schema manuellt genom att välja Lägg till rad. För varje rad väljer du fälttyp, fältnamn och anger en beskrivning.

      Skärmbild som visar det manuella sättet att skapa ett schema.

    • Om du vill skapa ett schema genom att ange JSON-kod väljer du alternativet Kodredigerare enligt följande bild. Om du ser meddelandet: Om du väljer att använda kodredigeraren för att skapa schemat bör du tänka på att du inte kan växla tillbaka till UI-byggaren och välja Redigera.

      Skärmbild som visar kodredigeraren för att skapa ett schema.

      Ange JSON-koden i redigeraren.

      Skärmbild som visar JSON-koden i kodredigeraren för att skapa ett schema.

Hämta slutpunktsinformation i informationsfönstret

När du har skapat en anpassad slutpunktskälla är dess data tillgängliga för visualisering i livevyn.

Skärmbild som visar händelseströmmen i livevyn.

Fönstret Information har tre protokollflikar: Event Hub, AMQP och Kafka. Varje protokollflik har tre sidor: Grundläggande och SAS-nyckelautentisering. Dessa sidor erbjuder slutpunktsinformation med motsvarande protokoll för anslutning.

Basic visar namn, typ och status för din anpassade slutpunkt.

Skärmbild som visar grundläggande information i detaljrutan för livevyn av eventstream.

Sidan SAS-nyckelautentisering innehåller information om anslutningsnycklar och även en länk till exempelkoden, med motsvarande nycklar inbäddade, som du kan använda för att strömma händelserna till din händelseström. Informationen på sidan Nycklar varierar beroende på protokoll.

Evenemangshubb

Sidan SAS-nyckelautentisering på fliken Händelsehubb innehåller information om en händelsehubbs anslutningssträng. Informationen omfattar Händelsehubbnamn, Namn på delad åtkomstnyckel, Primärnyckel, Sekundär nyckel, Anslutningssträng primärnyckel, Anslutningssträng-sekundär nyckel.

Skärmbild som visar viktig information på informationspanelen i händelseströmmen.

Formatet för händelsehubben är standard för anslutningssträng och fungerar med Azure Event Hubs SDK. Med det här formatet kan du ansluta till din händelseström via Event Hubs-protokollet.

I följande exempel visas hur anslutningssträng ser ut i händelsehubbformat:

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

Om du väljer knappen Visa exempelkod visas java-koden som innehåller nödvändig information om anslutningsnycklar i händelsehubben. Kopiera och klistra in den i programmet för användning.

Skärmbild som visar exempelkod i detaljpanelen i livevyn av eventstream.

AMQP (Advanced Message Queuing Protocol)

AMQP-formatet är kompatibelt med AMQP 1.0-protokollet, som är ett standardmeddelandeprotokoll som stöder samverkan mellan olika plattformar och språk. Du kan använda det här formatet för att ansluta till din händelseström med hjälp av AMQP-protokollet.

Skärmbild som visar AMQP-nycklar i informationsrutan i livevyn Eventstream.

När du väljer Visa exempelkod-knappen visas den färdiga Java-koden med anslutningsinformation i AMQP-format.

Skärmbild som visar AMQP-exempelkod i fönstret Information i Eventstream-livevyn.

Kafka

Kafka-formatet är kompatibelt med Apache Kafka-protokollet, som är en populär distribuerad strömningsplattform som stöder databearbetning med högt dataflöde och låg latens. Du kan använda SAS-nyckelautentiseringsinformationen för Kafka-protokollformatet för att ansluta till din händelseström och strömma händelserna.

Skärmbild som visar Kafka-nycklar i eventstreams livevy på detaljpanelet.

När du väljer knappen Visa exempelkod visas java-koden som är redo att användas, inklusive nödvändiga anslutningsnycklar i Kafka-format. Kopiera den för din användning.

Skärmbild som visar Kafka-exempelkod i fönstret Information i eventstream-livevyn.

En tydlig guide om hur du använder den anpassade slutpunkten med Kafka-protokollet finns i denna handledning. Den innehåller detaljerade steg för strömning och användning av händelser med hjälp av den anpassade slutpunkten med Kafka-protokollet.

Anteckning

  • Du kan välja det protokollformat som passar dina programbehov och inställningar och sedan kopiera och klistra in anslutningssträng i programmet. Du kan också referera till eller kopiera exempelkoden, som visar hur du skickar eller tar emot händelser med hjälp av olika protokoll.
  • Om du vill avsluta exempelkodvyn väljer du Dölj exempelkod.

Konfigurera eventstream-mål för att använda scheman

För närvarande stöds endast Eventhouse-mål, anpassade slutpunkter och härledda strömmar för eventstreams med aktiverade utökade funktioner (t.ex. schemastöd). Det här avsnittet visar hur du lägger till och konfigurerar ett Eventhouse-mål när utökade funktioner (till exempel schemastöd) aktiveras för händelseströmmen.

Konfigurera schema för ett anpassat slutpunktsmål

  1. Välj Transformera händelser eller lägg till mål och välj sedan Anpassad slutpunkt.

  2. I fönstret Anpassad slutpunkt anger du ett namn för målet som vanligt.

  3. För Indataschema väljer du schemat för händelser. Det här fältet är det extra fält som du fyller i när du aktiverar schemastöd för en händelseström.

    Skärmbild som visar konfigurationssidan för anpassad slutpunkt.

    Detaljerade anvisningar om hur du konfigurerar ett anpassat slutpunktsmål finns i Lägga till en anpassad slutpunkt eller ett anpassat appmål i en händelseström.

Konfigurera scheman för en evenemangshus-destination

  1. Välj Transformera händelser eller lägg till mål och välj sedan Eventhouse.
  2. På sidan Eventhouse konfigurerar du följande schemarelaterade inställningar:

    1. För Indataschema väljer du ett eller flera scheman i listrutan.

      Skärmbild som visar konfigurationssidan för Eventhouse med ett indataschema valt.

      Anteckning

      Om du valde alternativet Dynamiskt schema via rubriker när du konfigurerade en Händelsehubbkälla kan du ha konfigurerat flera scheman för källan och mappat dem till olika egenskaper och deras värden.

    2. För Metod för att skapa tabell väljer du ett av alternativen beroende på dina krav: En enskild tabell med alla kombinerade scheman eller Separata tabeller för varje schema.

      Skärmbild som visar konfigurationssidan för Eventhouse med metoder för att skapa tabeller.

    3. För Skriv data med väljer du något av följande alternativ:

      • Endast nyttolast: Skriva extraherade nyttolastdata till tabellen. Om det finns flera indatascheman skickas data till flera tabeller.

      • Metadata och nyttolast: Skriv metadata och nyttolastdata till en enda tabell. Exempelkolumner: source , subject, type, data, osv.

        Skärmbild som visar konfigurationssidan för Eventhouse med alternativen för skrivdata.

      Detaljerade anvisningar om hur du konfigurerar ett Eventhouse-mål finns i Lägga till ett Eventhouse-mål i en händelseström.

Relaterat innehåll

En lista över källor som stöds finns i Lägga till en händelsekälla i en händelseström