Microsoft Fabric -tapahtumavirrat – yleiskatsaus
Microsoft Fabricin reaaliaikaisen älykkyyden tapahtumavirtojen ominaisuuden avulla voit tuoda reaaliaikaisia tapahtumia Fabriciin, muuntaa niitä ja reitittää ne sitten eri kohteisiin kirjoittamatta yhtään koodia (ilman koodausta). Luot tapahtumavirran, joka on Eventstream-kohteen esiintymä Fabric-palvelussa, lisäät tapahtumatietolähteitä tietovirtaan, voit halutessasi lisätä muunnoksia tapahtuman tietojen muuntamiseen ja reitittää sitten tiedot tuettuihin kohteisiin.
Tuo tapahtumia Fabriciin
Tapahtumavirtaominaisuuden avulla voit eri lähdeyhdistimien avulla noutaa tapahtumatietoja eri lähteistä. Saatavilla on enemmän lähteitä, kun otat parannetut ominaisuudet käyttöön tapahtumavirran luomisen aikana.
Tärkeä
Fabric-tapahtumavirtojen parannetut ominaisuudet ovat tällä hetkellä esiversiotilassa.
| Lähteet | Kuvaus |
|---|---|
| Azure Tapahtumatoiminnot | Jos sinulla on Azure-tapahtumatoiminto, voit käyttää tapahtumatoiminnon tietoja Microsoft Fabricissa Eventstreamin avulla. |
| Azure IoT -keskitin | Jos sinulla on Azure IoT -keskitin, voit käyttää IoT-tietoja Microsoft Fabriciin Eventstreamin avulla. |
| Azure SQL -tietokannan muutos tietokaappaus (CDC) | Azure SQL -tietokannan CDC-lähdeliittimen avulla voit siepata tilannevedoksen nykyisistä tiedoista Azure SQL -tietokannassa. Liitin valvoo ja kirjaa mahdolliset tulevat rivitason muutokset näihin tietoihin. |
| PostgreSQL-tietokannan CDC | PostgreSQL-tietokannan Change Data Capture (CDC) -lähdeliittimen avulla voit kaapata tilannevedoksen nykyisistä tiedoista PostgreSQL-tietokantaan. Liitin valvoo ja kirjaa mahdolliset tulevat rivitason muutokset näihin tietoihin. |
| MySQL-tietokannan CDC | Azure MySQL -tietokannan Change Data Capture (CDC) Source -liittimen avulla voit siepata tilannevedoksen nykyisistä tiedoista Azure Database for MySQL -tietokannassa. Voit määrittää valvottavat taulukot, ja tapahtumavirta kirjaa mahdolliset tulevat rivitason muutokset taulukoihin. |
| Azure Cosmos DB CDC | Microsoft Fabric -tapahtumavirtojen Azure Cosmos DB Change Data Capture (CDC) -lähdeliittimen avulla voit tallentaa tilannevedoksen nykyisistä tiedoista Azure Cosmos DB -tietokannassa. Liitin valvoo ja kirjaa mahdolliset tulevat rivitason muutokset näihin tietoihin. |
| Google Cloud Pub/Sub | Google Pub/Sub on viestipalvelu, jonka avulla voit julkaista ja tilata tapahtumavirtoja. Voit lisätä Google Pub/Subin lähteeksi tapahtumavirtaasi reaaliaikaisten tapahtumien sieppaamiseksi, muuntamiseksi ja reitittämiseksi eri kohteisiin Fabricissa. |
| Amazon Kinesis -tietovirrat | Amazon Kinesis Data Streams on erittäin skaalattava, erittäin kestävä tietojen käsittely ja käsittelypalvelu, joka on optimoitu tietojen suoratoistoa varten. Integroimalla Amazon Kinesis Data Streamsin lähteeksi tapahtumavirtaasi voit käsitellä reaaliaikaisia tietovirtoja saumattomasti, ennen kuin reitität ne useisiin kohteisiin Fabricissa. |
| Confluent Cloud Kafka | Confluent Cloud Kafka on suoratoistoympäristö, joka tarjoaa tehokkaita tietojen suoratoisto- ja käsittelytoimintoja Apache Kafkan avulla. Integroimalla Confluent Cloud Kafkan lähteeksi tapahtumavirtaasi voit käsitellä reaaliaikaisia tietovirtoja saumattomasti, ennen kuin reitität ne useisiin kohteisiin Fabricissa. |
| Azure Blob -säilön tapahtumat | Azure Blob -säilön tapahtumat käynnistyvät, kun asiakas luo, korvaa tai poistaa blob-objektin. Liittimen avulla voit linkittää Blob-säilön tapahtumat Fabric-tapahtumiin reaaliaikaisessa keskuksessa. Voit muuntaa nämä tapahtumat jatkuviksi tietovirroiksi ja muuntaa ne ennen niiden reititystä eri kohteisiin Fabricissa. |
| Fabric Workspace Item -tapahtumat | Fabric Workspace Item -tapahtumat ovat erillisiä Fabric-tapahtumia, jotka ilmenevät, kun Fabric-työtilaan tehdään muutoksia. Näihin muutoksiin kuuluu Fabric-kohteen luominen, päivittäminen tai poistaminen. Fabric-tapahtumavirtojen avulla voit siepata nämä Fabric-työtilatapahtumat, muuntaa niitä ja reitittää ne eri kohteisiin Fabricissa jatkoanalyyseja varten. |
| Mallitiedot | Voit valita polkupyöriä, keltaista taksia tai pörssitapahtumia mallitietolähteeksi tietojen käsittelytestauksen aikana tapahtumavirran määrittämisen aikana. |
| Mukautettu päätepiste (eli mukautettu sovellus vakiotoiminnossa) | Mukautetun päätepisteen ominaisuuden avulla sovelluksesi tai Kafka-asiakasohjelmasi voivat muodostaa yhteyden Eventstreamiin ühendusstring avulla, mikä mahdollistaa suoratoistettavien tietojen sujuvan käsittelytapahtumavirtaan. |
Tapahtumien käsittely koodittamatta -käyttökokemusta käyttämällä
Vedä ja pudota -käyttökokemus tarjoaa intuitiivisen ja helpon tavan luoda tapahtuman tietojen käsittely-, muuntamis- ja reitityslogiikka kirjoittamatta koodia. Päästä päähän -tietovuon kaavio tapahtumavirrassa voi tarjota kattavan käsityksen tiedonkulusta ja organisaatiosta. Tapahtumankäsittelyeditori on koodittomuuskokemus, jonka avulla voit suunnitella tapahtuman tietojen käsittelylogiikan vetämällä ja pudottamalla.
| Muunnos | Kuvaus |
|---|---|
| Suodata | Suodata muunnos -toiminnolla voit suodattaa tapahtumia syötteessä olevan kentän arvon perusteella. Tietotyypistä (luvusta tai tekstistä) riippuen muunnos säilyttää valittua ehtoa vastaavat arvot, kuten is null tai is not null. |
| Kenttien hallinta | Hallitse kenttiä -muunnoksen avulla voit lisätä, poistaa, muuttaa tietotyyppiä tai nimetä uudelleen syöte- tai toisesta muunnoksesta peräisin olevia kenttiä. |
| Yhdistelmä | Koosteen muunnoksen avulla voit laskea koosteen (Summa, Pienin, Suurin tai Keskiarvo) aina, kun uusi tapahtuma ilmenee tietyn ajanjakson aikana. Tämä toiminto sallii myös näiden laskettujen sarakkeiden uudelleennimeämisen sekä koosteen suodattamisen tai osittamisen tietojen muiden dimensioiden perusteella. Samassa muunnoksen koosteessa voi olla yksi tai useampi kooste. |
| Ryhmittele | Ryhmittely muunnoksen avulla voit laskea koosteita kaikista tapahtumista tietyn aikaikkunan sisällä. Voit ryhmitellä yhden tai useamman kentän arvojen mukaan. Koostemuunnos sallii sarakkeiden uudelleennimeämisen, mutta tarjoaa enemmän koostamisvaihtoehtoja ja monimutkaisempia aikaikkunoiden asetuksia. Koosteen tavoin voit lisätä useamman kuin yhden koosteen muunnoksen mukaan. |
| Liitto | Yhdistä-muunnoksen avulla voit yhdistää vähintään kaksi solmua ja lisätä tapahtumia, joissa on jaettuja kenttiä (samalla nimellä ja tietotyypillä) yhteen taulukkoon. Kentät, jotka eivät täsmää, pudotetaan eikä niitä sisällytetä tulokseen. |
| Laajenna | Laajenna matriisi -muunnoksen avulla voit luoda uuden rivin matriisin kullekin arvolle. |
| Liittyminen | Liity-muunnoksen avulla voit yhdistää tietoja kahdesta tietovirrasta niiden välisen ehdon perusteella. |
Jos otit parannetut ominaisuudet käyttöön luodessasi tapahtumasäilöä, muunnostoimintoja tuetaan kaikissa kohteissa (johdettu virta toimii välisiltana joissakin kohteissa, kuten mukautettu päätepiste ja refleksi). Jos et ole tehnyt niin, muunnostoiminnot ovat käytettävissä vain Lakehouse- ja KQL-tietokannan (tapahtumien käsittely ennen tietojen käsittelyä) kohteissa.
Tapahtumien reititys kohteisiin
Fabric-tapahtumavirrat-ominaisuus tukee tietojen lähettämistä seuraaviin tuettuihin kohteisiin.
| Kohde | Kuvaus |
|---|---|
| Mukautettu päätepiste (eli mukautettu sovellus vakiotoiminnossa) | Tämän kohteen avulla voit helposti reitittää reaaliaikaiset tapahtumat mukautettuun päätepisteeseen. Voit yhdistää omat sovelluksesi tapahtumavirtaan ja käyttää tapahtuman tietoja reaaliaikaisesti. Tämä kohde on hyödyllinen, kun haluat reaaliaikaisten tietojen lähtevän ulkoiseen järjestelmään Microsoft Fabricin ulkopuolella. |
| KQL-tietokanta | Tämän kohteen avulla voit käsitellä reaaliaikaisia tapahtumatietoja KQL-tietokannassa, jossa voit käyttää tehokasta Kusto Query Languagea (KQL) tietojen kyselyyn ja analysointiin. Kusto-tietokannan tietojen avulla voit saada syvällisempää tietoa tapahtumatiedoistasi ja luoda monipuolisia raportteja ja koontinäyttöjä. Voit valita kahdesta käsittelytilasta: Suora käsittely ja Tapahtumien käsittely ennen käsittelyä. |
| Lakehouse | Tämän kohteen avulla voit muuntaa reaaliaikaisia tapahtumiasi ennen niiden sisäänomista Lakehouse-taloosi. Reaaliaikaiset tapahtumat muuntuvat Delta Lake -muotoon ja tallentavat sitten nimetyt Lakehouse-taulukot. Tämä kohde tukee tietovarastointitilanteita. |
| Refleksi | Tämän kohteen avulla voit yhdistää reaaliaikaiset tapahtumatietosi suoraan Refleksiin. Refleksi on älykäs agenttityyppi, joka sisältää kaikki tiedot, joita tarvitaan tietoihin yhdistämiseen, olosuhteiden valvontaan ja toimiin. 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. |
| Johdettu tietovirta | Johdettu tietovirta on erityinen kohdetyyppi, jonka voit luoda lisättyäsi tietovirtatoimintoja, kuten Suodata tai Hallitse kenttiä, tapahtumavirtaan. Johdettu tietovirta edustaa muunnettua oletusvirtaa suoratoiston käsittelyn jälkeen. Voit reitittää johdetun tietovirran useisiin kohteisiin Fabricissa ja tarkastella johdettua tietovirtaa reaaliaikaisessa keskuksessa. |
Voit liittää useita kohteita tapahtumavirrassa vastaanottamaan tietoja samanaikaisesti tapahtumavirrasta vuorovaikutuksetta keskenään.
Muistiinpano
Suosittelemme, että käytät Microsoft Fabric -tapahtumavirtojen ominaisuutta, jossa on vähintään neljä kapasiteettiyksikköä (SKU: F4)
Parannetut ominaisuudet (esikatselu)
Saatavilla on enemmän ominaisuuksia, lähteitä ja kohteita, kun otat Parannetut ominaisuudet (esikatselu) -asetuksen käyttöön tapahtumavirran luomisen aikana. Parannetut ominaisuudet (esikatselu) ja Vakio-ominaisuudet -välilehtien avulla saat lisätietoja muista parannetuilla ominaisuuksilla tuetuista lähteistä ja kohteista.
Seuraavassa on joitakin muita huomionarvoisia parannettujen ominaisuuksien (esikatselu) ominaisuuksia:
- Muokkaustila ja reaaliaikainen näkymä. Tutustu kahteen erilliseen tilaan suoratoiston käsittelyn visualisointia ja suunnittelua varten.
- Oletus- ja johdettuja tietovirtoja. Luo jatkuva tietovirtojen työnkulku suunnittelemasi muodon avulla tapahtumasuorittimella, jota voidaan käyttää myöhemmin reaaliaikaisessa keskuksessa.
- Tietovirtojen reititys sisällön perusteella. Muunna ja reititä tietovirtoja minne tahansa Fabricissa tapahtumankäsittelyllä suunnittelemasi tietovirran sisällön perusteella.
Liittyvä sisältö
Palaute
Tulossa pian: Vuoden 2024 aikana poistamme asteittain GitHub Issuesin käytöstä sisällön palautemekanismina ja korvaamme sen uudella palautejärjestelmällä. Lisätietoja on täällä: https://aka.ms/ContentUserFeedback.
Lähetä ja näytä palaute kohteelle