Jaa

Reititä tietovirtoja Fabric-tapahtumavirtojen sisällön perusteella (esikatselu)

  • Artikkeli

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.

Tärkeä

Fabric-tapahtumavirtojen parannetut ominaisuudet ovat tällä hetkellä esiversiotilassa.

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ä: Näyttöyhteys kaksi tai useampia tietovirtoja, joissa on samannimiset ja tietotyyppiset ja jaetut kentät, yhdeksi tietovirraksi. 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 sinulle mahdollisuuden muuntaa reaaliaikaisia tapahtumiasi ennen käsittelystä lakehouseesi. Reaaliaikaiset tapahtumat muuntuvat Delta Lake -muotoon ja tallentavat sitten nimetyt Lakehouse-taulukot. Tämä kohde auttaa tietojen varastointiskenaarioiden käytössä.

  • KQL-tietokanta: Tämän kohdesijainnin avulla voit käsitellä reaaliaikaisia tapahtumatietoja KQL-tietokantaan, jossa voit käyttää tehokasta Kusto Query Languagea (KQL) tietojen kyselyyn ja analysointiin. KQL-tietokannan tietojen avulla voit saada syvällisempiä tietoja tapahtumatiedoistasi ja luoda monipuolisia raportteja ja koontinäyttöjä.

  • Refleksi: Tämän kohteen avulla voit yhdistää reaaliaikaiset tapahtumatiedot suoraan Refleksiin. Refleksi 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 kuvioita, Reflex 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 KQL-tietokanta on määritetty raakatietojen tallentamista varten, toinen KQL-tietokanta on suodatettuja tietovirtoja varten ja Lakehousea käytetään koostearvojen tallentamiseen.

Näyttökuva sisällön perusteella reititetyistä tapahtumista.

Jos haluat muuntaa ja reitittää tietovirtasi sisällön perusteella, noudata muokkaamisen ja julkaise tapahtumavirran vaiheita ja ala suunnitella tietovirran käsittelylogiikkaa.

Liittyvä sisältö