Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Funktionen för flera schemadragningar i Microsoft Fabric-händelseströmmar stöder slutsatsdragning av flera scheman från olika källor och själva händelseströmmen. Du kan använda funktionen för att utforma olika datatransformeringsvägar genom att hämta ett av de härledda schemana med omfattande flexibilitet. Den här möjligheten möjliggör sömlös dataintegrering och bearbetning som tillgodoser miljöer med komplexa och flera dataformer. Den tar itu med de utmaningar som användare tidigare stötte på med slutsatsdragning med ett enda schema.
Den här funktionen är användbar för följande scenarier:
Visa och uppdatera härledda scheman: De härledda schemana i en händelseström kan granskas och verifieras på flera platser. Om några datatyper i specifika fält är felaktigt angivna tillåter funktionen nödvändiga korrigeringar.
Använd olika härledda scheman för olika transformeringsvägar: När du konfigurerar den första operatornoden efter den mellersta standardströmmen måste du välja ett av de härledda schemana. Det här valet möjliggör att transformationsvägen utformas med händelsekolumner från det valda schemat.
Olika transformeringssökvägar kan använda olika scheman för datatransformering i en enda händelseström. Den här möjligheten ökar flexibiliteten i datatransformering.
Få en välorganiserad dataförhandsgranskning och ett testresultat: Med flera schemaslut kan du visa förhandsgranskningsdata och testresultat på ett välorganiserat sätt. Tidigare visades data med flera scheman med blandade kolumner under dataförhandsgranskning eller testresultat. Den här typen av uppvisning ledde till förvirring. Nu kan du välja ett härledt schema för att filtrera de förhandsgranskade eller testade data. Endast de data som matchar det valda schemat visas på fliken för dataförhandsgranskning eller testresultat.
Eliminera redigeringsfelen på transformeringssökvägar när du använder redigeringsläget igen: Den här funktionen bevarar schemat som tillämpas i transformeringssökvägar (till exempel operatorer) när händelseströmmen har publicerats. Den här funktionen eliminerar redigeringsfel som tidigare visades på transformeringssökvägar i händelseströmmar med ett enda schema, när inget matchande schema fanns i redigeringsläge .
Du kan nu fortsätta att justera operatorkonfigurationer i transformeringssökvägar och publicera händelseströmmen även om det nyligen uppskjutna schemat inte överensstämmer med det som används i operatorkonfigurationer, eller om inget schema härleds vid återförsök till redigeringsläge .
Mappa varje schema till en källa: När du härleder flera scheman hjälper en händelseström till att mappa varje schema till en källa. Om händelseströmmen inte kan identifiera datakällan med det härledda schemat uppmanas du att manuellt mappa schemat till en lämplig källa. Den här mappningen säkerställer att varje schema har en associerad källa för transformeringsdesign. Det ger insyn i var schemat kommer ifrån.
Så här fungerar det
Scheman härleds baserat på de data som förhandsgranskas från båda källorna och händelseströmmen inom ett tidsintervall. Om det inte finns några data i källan eller händelseströmmen, eller om källan inte stöder en dataförhandsgranskning, härleds inget schema. Om de förhandsgranskade dataändringarna (till exempel nya fält läggs till eller datatypen ändras) härleds ett nytt schema.
Om operatorerna har konfigurerats i din händelseström behålls det schema som du använde för operatörskonfigurationer när du publicerar händelseströmmen. När du använder redigeringsläget igen tillämpas det här kvarhållna schemat på operatorerna. Den här metoden åtgärdar redigeringsfel som uppstår när det härledda schemat skiljer sig från det som används i operatorkonfigurationer, eller om inget schema härleds.
Förutsättningar
- Åtkomst till en arbetsyta med deltagare eller högre behörigheter där din eventstream finns.
Aktivera inferens för flera scheman
Om du vill använda flera schemainferenser måste du aktivera den här funktionen i din händelseström. Du kan aktivera den i både nya och befintliga eventstreams.
- Öppna din händelseström, gå till Inställningar och välj sedan Schema.
- Slå på växlingsknappen för flerschema-deducring och välj sedan Verkställ.
Anmärkning
När du har aktiverat funktionen kan du inte inaktivera den för den här händelseströmmen.
Visa och uppdatera de härledda schemana
Om din händelseströms källa stöder förhandsversionen av data eller om händelseströmmen innehåller data kan scheman automatiskt härledas från förhandsgranskningsdata. Gå till Redigeringsläge och välj sedan fliken Uppskjutet schema för att granska och ändra scheman i händelseströmmen.
Välj schemanamnet för att visa alla kolumner (dvs. fält) i schemat. Om några fält härleds felaktigt kan du korrigera dem. Du kan till exempel korrigera fältnamn, korrigera datatyper eller lägga till och ta bort fält. Välj Uppdatera för att spara ändringar.
Anmärkning
Du använder det här steget för att korrigera hur en händelseström tolkar dina data när det här angivna schemat är felaktigt. Om du vill konvertera datatyper under bearbetningen använder du operatorn Hantera fält i transformeringssökvägen.
Använda olika scheman i transformeringsvägar
Funktionen för inferens av flera scheman möjliggör användning av olika scheman i olika transformeringsvägar. När du konfigurerar den första operatornoden efter standardströmmen väljer du ett objekt i listan Indataschema .
Om du väljer ett schema här kan du definiera transformeringslogik med hjälp av de fält som anges i schemat. Den filtrerar dock inte inkommande data. Även om en händelse saknar de markerade fälten bearbetas den fortfarande, med fälten kvar som null.
Om du till exempel väljer ett schema från Sp500stocks men du tar emot data från Cyklar, når händelsen fortfarande den anpassade slutpunkten. De markerade fälten visar null-värden.
Ett målpunkt för eventhouse mottar inte någon data i det här fallet.
Varje transformeringssökväg i en händelseström kan använda ett annat schema. I den första operatorn för varje sökväg efter standardströmmen kan du välja det schema som bäst matchar den sökvägens förväntade krav för datatransformering.
Om en transformeringssökväg inte innehåller några operatorer kan du välja indataschemat direkt i målkonfigurationen. Indataschemat fungerar inte som ett filter. Den fungerar som schemaindata för backend-frågegenerering.
Visa data efter schema i dataförhandsgranskningen och testresultatet
När du har lagt till en källa som stöds av förhandsversionen eller när data börjar flöda till en publicerad händelseström kan du ange Redigeringsläge och välja ett härledt schema för att visa matchade testdata.
Du kan välja ett härlett schema i redigeringsläge för att visa testresultatet om källan stöder dataförhandsgranskning, eller om det inte gör det men om händelseströmmen publiceras och datan flödar in i standardströmmen.
Om du vill visa schemainformationen som används i noderna (operatorer eller mål) i transformeringssökvägen väljer du operatorn eller målnoden och väljer sedan Visa schema.
Du kan också välja ett härlett schema för att filtrera de förhandsgranskade data i Live-vyn. Den här filtreringen kan se till att endast de data som matchar det valda schemat visas på fliken Dataförhandsgranskning .
Anmärkning
Du använder schemat i livevyn för att organisera förhandsgranskningsdata. Dessa scheman härleds från förhandsgranskade livedata från de källor som stöds och händelseströmmen. Om du inte förhandsgranskar några data visas inget schema. Om det finns data med ett nytt schema skiljer sig schemat som visas i livevyn från schemat som tidigare visades i redigeringsvyn .
Mappa ett schema till källan
En händelseström mappar automatiskt de härledda schemana till sina respektive källor när schemanas ursprung identifieras. Om källan till exempel stöder dataförhandsgranskning och schemat härleds från dessa förhandsgranskningsdata mappar händelseströmmen schemat med källan i enlighet med detta.
Om datakällan inte stöder förhandsversionen av data måste du först publicera händelseströmmen och vänta tills data kommer. Växla sedan tillbaka till Redigeringsläge för att granska det härledda schemat. I det här fallet, eftersom händelseströmmen inte kan identifiera datakällan baserat på det här schemat, uppmanas du att mappa schemat manuellt till rätt källa.
Så här tilldelar du ett schema manuellt till en källa:
I redigeringsläge går du till fliken Uppskjutet schema och väljer Mappa till datakälla.
Välj datakällan för mappning och välj sedan Spara för att spara ändringarna.
Du kan också mappa schemat under den första användningen i transformeringsbanan. När du konfigurerar och sparar en operatör eller ett mål uppmanas du i en dialogruta att välja lämplig källa för schemat.
Vanliga frågor
Varför härleds inget schema när jag har lagt till en källa och uppdaterat testresultatet?
När du skapar en ny händelseström och lägger till en källa som inte stöder förhandsgranskning av data, kommer inget schema att härledas omedelbart, även efter att du har uppdaterat testresultatet.
Anta till exempel att du använder Azure Service Bus som anpassad slutpunktskälla. För att generera härledda scheman i det här fallet måste du publicera händelseströmmen först och vänta tills data kommer in i händelseströmmen. När data börjar flöda till din händelseström växlar du tillbaka till Redigeringsläge för att visa de härledda schemana. Dessa åtgärder är nödvändiga eftersom schemana härleds baserat på data som förhandsgranskas från både källan och händelseströmmen.
Om du i det här fallet använder det härledda schemat i en transformeringssökväg ser du till att mappa schemat manuellt till rätt källa på fliken Härlett schema.
Jag redigerade det härledda schemat, men data ändrades inte. Varför?
När du redigerar ett härledt schema ändras händelseströmmens tolkning av din inkommande datastruktur och typ, men de faktiska datavärdena och typerna ändras inte. Använd den här funktionen när du fastställer att det här schemat inte överensstämmer med ditt verkliga dataformat och din struktur, och du behöver exakta kolumntyper (dvs. fält) för nedströmsoperatorernas konfiguration.
Om du vill tillämpa ändringar på själva data (till exempel byta namn på fält eller konvertera typer) när du bearbetar data använder du operatorn Hantera fält i transformeringssökvägen.
Vad händer om schemat för mina data i den befintliga källan ändras när det har härledts?
Om datastrukturen ändras (till exempel om du lägger till nya fält eller ändrar datatypen) i en källa, härleds ett nytt schema när dessa nya data förhandsgranskas i den här händelseströmmen. Anledningen är att schemat härleds från de förhandsgranskningsdata.
Du kan granska och använda det nya schemat i redigeringsläge . Du kan också använda det nya schemat för att ordna förhandsgranskningsdata i Live-vyn. Om ditt tidigare schema används i en operatör eller ett mål, och händelseströmmen publiceras, behålls ditt tidigare schema och kan fortfarande visas i redigeringsläge .
Vilka är konsekvenserna av att publicera en händelseström om ett schema inte mappas till någon källa?
Schemat behålls inte i händelseströmmen eftersom det är ett tillfälligt schema och inga operator- eller målkonfigurationer använder det.
Vad händer om jag tar bort en befintlig källa som har ett mappat schema?
Om schemat som härleds från källan inte används i någon operator eller ett mål resulterar det inte i något fel när källan tas bort. Men om schemat som härleds från källan används i någon operator eller ett mål uppstår ett redigeringsfel.
För att fortsätta måste du mappa om schemat som härleds från den borttagna källan till en giltig källa innan du publicerar. Eller så kan du välja ett annat schema som indataschema för operatorn.
Varför visas ett extra schema när jag har aktiverat den här funktionen i en befintlig händelseström?
När du aktiverar flera schemaferenser i en befintlig händelseström och växlar till Redigeringsläge visas ett extra schema som innehåller blandade fält i vissa fall. Det här schemat kommer från den befintliga händelseströmmen, som du använde för operatörskonfigurationer. Som standard mappas den till alla källor eftersom händelseströmmen inte kan fastställa dess ursprung. Det här standardbeteendet skyddar kontinuiteten i den aktuella installationen och undviker fel.