Reititä tietovirtoja Fabric-tapahtumavirtojen sisällön perusteella
Tässä artikkelissa kerrotaan, miten voit reitittää tapahtumia Microsoft Fabric -tapahtumavirtojen sisällön perusteella.
Voit nyt käyttää kooditonta editoria Fabric-tapahtumavirtojen pääpohjalla monitasoisen suoratoiston käsittelylogiikan luomiseen koodia kirjoittamatta. Tämän ominaisuuden avulla voit räätälöidä, muuntaa ja hallita tietovirtoja entistä helpommin. Kun olet määrittänyt suoratoiston käsittelytoiminnot, voit lähettää tietovirtasi sujuvasti eri kohteisiin tietyn rakenteen ja virtatietojen mukaan.
Tuetut toiminnot
Seuraavassa on luettelo toiminnoista, joita tuetaan reaaliaikaisessa tietojenkäsittelyssä:
Kooste: Tue SUM-, AVG-, MIN- ja MAX-funktioita, jotka suorittavat laskutoimituksia arvosarakkeessa ja palauttavat yksittäisen tuloksen.
Laajenna: Laajenna matriisiarvo ja luo uusi rivi jokaiselle matriisin arvolle.
Suodatin: Valitse tai suodata tiettyjä rivejä tietovirrasta ehdon perusteella.
Ryhmittelyperuste: Koosta kaikki tapahtumatiedot tietyssä aikaikkunassa, ja voit ryhmitellä yhden tai useamman sarakkeen.
Kenttien hallinta: Lisää, poista tai muuta tietovirtojen kentän tai sarakkeen tietotyyppiä.
Yhdistä: Yhdistä vähintään kaksi tietovirtaa samannimisen ja tietotyypin jaettujen kenttien kanssa yhteen tietovirtaan. Kentät, jotka eivät täsmää, pudotetaan.
Liity: Yhdistä tietoja kahdesta tietovirrasta niiden välisen ehdon perusteella.
Tuetut kohteet
Tuetut kohteet ovat seuraavat:
Lakehouse: Tämä kohde tarjoaa mahdollisuuden muuntaa reaaliaikaisia tapahtumiasi ennen käsittelyä lakehouse. Reaaliaikaiset tapahtumat muuntuvat Delta Lake -muotoon ja tallentavat sitten nimetyt Lakehouse-taulukot. Tämä kohde auttaa tietojen varastointiskenaarioiden käytössä.
Eventhouse: Tämän kohteen avulla voit käyttää reaaliaikaisia tapahtumatietojasi Eventhousessa, jossa voit käyttää tehokasta Kusto Query Languagea (KQL) tietojen kyselyyn ja analysointiin. Eventhouse-tietojen avulla voit saada syvällisempää tietoa tapahtumatiedoistasi ja luoda monipuolisia raportteja ja koontinäyttöjä.
Fabric Activator: Tämän kohteen avulla voit yhdistää reaaliaikaiset tapahtumatietosi suoraan Fabric Activatoriin. Activator on älykäs agenttityyppi, joka sisältää kaikki tiedot, joita tarvitaan tietoihin yhdistämiseen, olosuhteiden valvontaan ja toimintaan. Kun tiedot saavuttavat tietyt raja-arvot tai vastaavat muita malleja, aktivointitoiminto suorittaa automaattisesti asianmukaisia toimia, kuten ilmoittaa käyttäjille tai käynnistää Power Automate -työnkulut.
Mukautettu päätepiste (entinen mukautettu sovellus): Tässä kohdesijainnissa voit helposti reitittää reaaliaikaiset tapahtumat mukautettuun sovellukseen. Tämän kohteen avulla voit yhdistää omat sovelluksesi tapahtumavirtaan ja kuluttaa tapahtuman tietoja reaaliaikaisesti. Siitä on hyötyä, kun haluat reaaliaikaisten tietojen lähtevän ulkoiseen järjestelmään Microsoft Fabricin ulkopuolella.
Tietovirta: Tämä kohde edustaa toimintojen sarjan muuntamaa oletusarvoista raakatapahtumavirtaa, jota kutsutaan myös johdetuiksi tietovirroiksi. Kun tietovirta on luotu, voit tarkastella sitä reaaliaikaisessa keskuksessa.
Seuraavassa esimerkissä näytetään, miten kolme erillistä Fabric-tapahtumavirran kohdetta voi tarjota erillisiä funktioita yksittäiselle tietovirran lähteelle. Yksi Eventhouse on nimetty raakadatan tallentamista varten, toinen Eventhouse on suodatettuja tietovirtoja varten ja Lakehousea käytetään koostearvojen tallentamiseen.
Jos haluat muuntaa ja reitittää tietovirtasi sisällön perusteella, noudata muokkaamisen ja julkaise tapahtumavirran vaiheita ja ala suunnitella tietovirran käsittelylogiikkaa.