Mikä on Fabric Activator?

Fabric Activator on kooditon tapahtumantunnistusmoottori, joka muuntaa datavirrat automatisoiduiksi toiminnoiksi. Se käynnistää automaattisesti toiminnot, kun tietyt kuviot tai olosuhteet havaitaan tietolähteissä. Se seuraa jatkuvasti näitä tietolähteitä matalalla viiveellä (subsekunnin tilassa olemattomille säännöille suoratoistotietojen osalta) ja käynnistää toimenpiteitä, kun kynnysarvot täyttyvät tai tietyt kuviot havaitaan. Näihin toimintoihin voi kuulua sähköpostien tai Teams-ilmoitusten lähettäminen, Power Automate -työnkulujen käynnistäminen tai integroituminen kolmannen osapuolen järjestelmiin.

Ydinarkkitehtuuri

Aktivaattori on tapahtumien tunnistus- ja sääntömoottori Fabric Real-Time älykkyyspinon ytimessä. Arkkitehtonisesti se toimii älykkäänä tarkkailijana , joka kuluttaa suuren nopeuden tietovirtoja, arvioi sääntöehtoja lähes reaaliaikaisesti ja käynnistää automatisoituja jatkotoimia tapahtumatilojen muutosten perusteella.

Se sopii reaktiiviseen, tapahtumavetoiseen arkkitehtuuriin, jossa data virtaa jatkuvasti ja Activator tekee päätöksiä lähes reaaliaikaisten tapahtumadatan tilapitoisten arviointien perusteella.

kaavio, joka näyttää Fabric Activator.

• Tapahtumien lähteet

  Aktivaattori yhdistää suoraan tapahtumavirtoihin, jotka vastaanottavat dataa eri tuottajilta (Azure Event Hubs, IoT-laitteet, mukautetut päätelaitteet ja muut lähteet). Nämä tietovirrat toimivat tapahtumien lähteenä, ja Activator voi tilata yhden tai useamman tapahtumavirran tietojen muutosten seuraamiseksi. Muita tapahtumalähteitä voisivat olla Fabric- tai Azure-tapahtumat tai Aktivaattori, joka kuuntelee Power BI-raporttia tai Real-Time-hallintapaneeli.

• Tapahtumat ja objektit

  Tapahtumat ovat yksittäisiä tietueita (esimerkiksi telemetriasignaali tai tiedoston pudotus), jotka on vastaanotettu eventstreamin kautta. Nämä tapahtumat ryhmitellään objekteiksi yhteisen tunnisteen perusteella (esimerkiksi kaikki saman laitteen tapahtumat ryhmitellään yhteen käyttämällä device_id, tai kaikki pyöräaseman tapahtumat ryhmitellään seuraavasti bikepoint_id). Säännöt arvioidaan sitten objektikohtaisesti, mikä mahdollistaa tarkan tunnistamisen (esimerkiksi anturia kohti tai resurssikohtaisesti).

• Säännöt ja ehdot

  Jokainen aktivaattori sisältää yhden tai useamman sääntöjen, joita arvioidaan jatkuvasti. Nämä säännöt voivat olla yksinkertaisia vertailuja (value < threshold) tai ehtoja, jotka seuraavat muutoksia ajan kuluessa, kuten BECOMES, DECREASES, INCREASESEXIT RANGE, tai datan puuttuminen (sydämenlyönti). Aktivointi varmistaa objektikohtaisen tilan seurannan, mikä mahdollistaa monimutkaisen kuvion tunnistamisen ajan kuluessa.

• Actions

  Kun säännön ehto täyttyy, aktivaattori voi käynnistää:

  • putkistoja, muistikirjoja, datavirtoja, User Data Functionsia (UDF) (esikatselu) tai spark-tehtävien määrittelyjä Fabric-ohjelmassa.

  • Ulkoiset toiminnot Power Automate:n kautta.

  • Lähetä Teams-viesti yksilölle, ryhmälle tai kanavalle.

  • Lähetä sähköpostia.

• Hälytyksen hallinta ja sääntöjen testaus

  Activator tarjoaa esikatselu- ja vaikutusarviot ennen sääntöjen aktivointia ja näyttää, kuinka usein sääntö olisi käynnistynyt historiallisille tiedoille. Nämä ominaisuudet auttavat estämään hälytyksiä roskapostia ja yliammuntaa. Sisäisesti osavaltiosiirtymiä hallitaan aiheuttamaan melua (esimerkiksi arvon on ylitettävä raja-arvo, ei pelkästään sen alapuolella).

• Valvonta ja kustannusten hallinta

  Kustannukset tulevat näkyviin vain silloin, kun aktivoijat ovat aktiivisessa toiminnassa. Aktivaattoriinstanssit on rajattu Fabric-kapasiteetteihin ja niitä voidaan seurata työtilan kautta. Suorituksenaikaiset lokit ja telemetriatiedot ovat käytettävissä tapahtumavirkojen ja putkitulosteiden kautta.

Käyttöönottomalli

Ota käyttöön aktivointiinstanssit jokaiselle työtilalle ja sido ne tiettyihin tietolähteisiin. Useat aktivaattorit voivat seurata samaa virtaa, joten voit käyttää rinnakkaisia sääntöarviointeja eri liiketoimintatoiminnoille. Koska aktivaattori on kapasiteettirajoitettu, pay-as-you-go -hinnoittelu koskee vain, kun säännöt ovat aktiivisesti käytössä. Tämä hinnoittelumalli tarjoaa kustannustehokkuutta ajoittaisissa havaitsemistilanteissa. Tunnetuista rajoitteista katso Aktivaattorin rajoitukset.

Real-Time-älyn integrointipisteet

Välittäjän aktivaattori

Jotta Activatoria voisi käyttää tehokkaasti suurissa järjestelmissä, koordinoi sen toiminta muiden Fabric-komponenttien kanssa. Optimoi asetukset sen mukaan, kuinka paljon dataa käsittelet, kuinka monta objektia seuraat ja kuinka monimutkaisia sääntösi ovat. Tässä osiossa tutkitaan, miten Activator voidaan orkestroida muiden palveluiden kanssa sekä optimoida tunnistuslogiikkaa ja ajonaikaista käyttäytymistä tukemaan matalan viiveen (nopeaa) ja kustannustehokasta automaatiota laajassa mittakaavassa.

Activatorilla on keskeinen rooli tapahtumapohjaisissa jaksoissa arvioimalla tiedot saapumispisteessä ja käynnistämällä toimintoja tuotantovirran alla. Tyypillisiä orkestrointimalleja ovat:

Keskeiset käsitteet

Fabric Activator seuraa jatkuvasti dataasi ja havaitsee nopeasti, kun määrittelemäsi ehdot täyttyvät, vaikka data muuttuisi ajan myötä. Ytimeltään Aktivaattori käsittelee tapahtumavirran kautta emittoituja reaaliaikaisia tapahtumia, arvioi sääntöehdot loogisia objekteja kohden ja käynnistää toimintoja tilanvaihtojen yhteydessä.

Käytä seuraavia käsitteitä rakentaaksesi ja käynnistääksesi automatisoituja toimintoja ja vastauksia Fabric Activatorissa.

Tapahtumalähteet ja tapahtumat

Fabric Activator käsittelee kaikkia tietolähteitä tapahtumavirtoina. Tapahtuma edustaa havaintoa objektin tilasta ja sisältää yleensä objektin tunnuksen, aikaleiman ja valvottavat kenttien arvot.

Activatoriin sisäänotetut tapahtumat ovat peräisin seuraavista:

• Eventstream, joka tukee useita ylävirran lähteitä (esimerkiksi Azure Event Hubs, IoT Hub, Blob Storage triggers). Eventstream on Microsoft Fabric -ohjelmassa oleva tietty esinetyyppi, jonka avulla voit vastaanottaa, muuntaa ja reitittää reaaliaikaisia tapahtumia ilman koodia kirjoittamista. Fabric Activator seuraa tapahtumavirtaa ja ryhtyy automaattisesti toimiin, kun määriteltyjä kuvioita tai kynnysarvoja havaitaan. Aktivoija voi myös tilata kaksi tai useampia tapahtumatoimintoja tietojen muutosten tarkkailemiseksi. Tapahtumavirrat vaihtelevat esiintymistiheyden mukaan. Esimerkiksi IoT-tunnistimet lähettävät tapahtumia useita kertoja sekunnissa ja logistiikkajärjestelmät luovat tapahtumia satunnaisesti esimerkiksi silloin, kun paketteja skannataan toimituspaikoissa.
• Fabric-tapahtumat. Esimerkiksi Fabric-työtilan esinetapahtumat ovat erillisiä Fabric-tapahtumia, jotka tapahtuvat, kun Fabric Workspaceen tehdään muutoksia. Näihin muutoksiin kuuluu Fabric-tuotteen luominen, päivittäminen tai poistaminen.
• Azure-tapahtumat. Esimerkiksi Azure Blob Storage -tapahtumat käynnistyvät, kun asiakas luo, korvaa tai poistaa blobin.
• Liiketoimintatapahtumat. Voit asettaa hälytyksiä suoraan liiketoimintatapahtumista automatisoidaksesi toiminnot, kun tietyt liiketoimintaolosuhteet ilmenevät.
• Fabric Ontologian liiketoimintayksiköt (esikatselu). Ontologian liiketoimintayksiköille voidaan määritellä sääntöjä, jotka käynnistävät hälytyksiä ja automatisoituja toimia, mahdollistaen operatiivisen päätöksenteon mallinnettuun dataan.
• Power BI -raportti. Tässä tapauksessa tapahtumat ovat jaksollisia havaintoja, jotka perustuvat Power BI:n semanttisen mallin (aiemmin tunnettu nimellä dataset) päivitysaikatauluun. Nämä havainnot saattavat tapahtua päivittäin tai viikoittain, mikä muodostaa hitaasti etenevän tapahtumavirran. Aktivaattori integroituu myös Power BI service -palveluun ilmoittaakseen käyttäjille, kun uusi rivi ilmestyy julkaistussa raportissa, mahdollistaen säännöt visuaalisten muutosten seuraamiseen sekä ilmoitusten tai myöhempien toimintojen käynnistämiseen.
• Fabric Real-Time hallintapaneeli.

Jokainen tapahtuma sisältää:

• Aikaleima
• hyötykuorma (jäsennetty tai puolirakenteinen tieto)
• Yksi tai useampi määrite, jota käytetään objektintunnistuksessa (esimerkiksi device_id, bikepoint_id)

Objects

Fabric Activatorissa seuraamiasi entiteettejä kutsutaan liiketoimintaobjekteiksi, jotka voivat olla joko fyysisiä tai käsitteellisiä. Esimerkkejä fyysisistä objekteista ovat pakastimet, ajoneuvot, paketit ja käyttäjät, sekä käsitteelliset objektit, kuten mainoskampanjat, asiakastilit ja käyttäjäistunnot.

Jos haluat mallintaa liiketoimintaobjektin Activatorissa, yhdistä vähintään yksi tapahtumavirta, valitse sarake, jota käytetään objektitunnuksena, ja määritä kentät, joita haluat käsitellä objektin ominaisuutena.

Termi objektiesiintymä viittaa tiettyyn esimerkkiin liiketoimintaobjektista, kuten tietystä pakastimesta, ajoneuvosta tai käyttäjäistunnosta. Objekti puolestaan viittaa yleensä yleiseen määritelmään tai luokkaan (esimerkiksi pakastimeen tyyppinä). Termiä populaatio käytetään valvottavan objektiesiintymän koko joukkoon.

Objektin luonti on implisiittistä: Aktivointi ryhmittelee tapahtumat käyttäen määritettyä objektiavainta. Säännöt on rajoitettu objekteihin, mikä tarkoittaa, että kaikki arviointilogiikka on objektin huomioon otettavaa ja riippumatonta kaikissa esiintymissä. Esimerkiksi säännön valvonta bikepoint_id luo erillisiä loogisia arviointeja kullekin yksilölliselle pyöräasemalle.

Rules

Säännöt määrittävät ehdot, jotka haluat tunnistaa objekteissasi, ja toiminnot, jotka suoritetaan, kun nämä ehdot täyttyvät. Esimerkiksi sääntö pakastinobjektista saattaa havaita, kun lämpötila nousee turvallisen raja-arvon yläpuolelle, ja lähettää automaattisesti sähköposti-ilmoituksen määritetylle teknikolle.

Activatorin säännöt voivat olla tilattomia tai tilallisia:

• Tilattomat säännöt arvioivat jokaisen tapahtuman erikseen (esimerkiksi arvo < 50).
• Tilalliset säännöt ylläpitävät muistia tapahtumien välillä objektikohtaisesti (esimerkiksi arvo PIENENEE, MUUTTUU, EXIT RANGE).

Aktivaattori tukee myös sääntöjen luomista Fabric Data Warehouse SQL-kyselytulosten (esikatselu) perusteella. Voit määritellä sääntöjä, jotka arvioivat SQL-kyselyn konfiguroitavalla aikataululla, tarkistavat ehdot tulosjoukosta ja käynnistävät toiminnot, kun ehdot täyttyvät. Tämä ominaisuus mahdollistaa varastodatan seurannan ilman suoratoistolähteitä. Lisätietoja löytyy kohdasta Luo varoitussääntö SQL-kyselylle.

Tilallinen arviointi perustuu:

• Delta-tunnistus: Seuraa aiempien ja nykyisten tapahtuma-arvojen välisiä muutoksia.
• Ajallinen sekvensointi: Arvioi aikaperusteisia olosuhteita, kuten tapahtumien poissaoloa (sydämenlyönnin havaitseminen).
• Osavaltioiden siirtymät: Säännöt aktivoituvat vain uuteen osavaltioon astuessa, estäen toistuvat ampumiset muuttumattomissa olosuhteissa.

Sääntöjä arvioidaan jatkuvasti. Tilattomien tietojen suoratoistosääntöjen osalta järjestelmä reagoi millisekunneissa. Aggregaatioita sisältävissä säännöissä viive riippuu katseluikkunasta ja myöhäisen saapumisen sietokyvystä. Lisätietoja löytyy osoitteesta Latency in Activator.

Actions

Kun säännön ehdot täyttyvät ja toiminto käynnistetään, sääntö aktivoituu. Tuettuja toimien tavoitteita ovat muun muassa seuraavat:

• Fabric-putket (datan siirtoon, rikastamiseen).
• Fabric-muistikirjat (koneoppimisen pisteytykseen, diagnostiikkaan).
• Fabric spark -työt (erä- ja suoratoistotöihin).
• Fabric-datavirrat (datan siirtoon ja muunnokseen).
• Fabric User Data Functions (esikatselu) (räätälöidylle liiketoimintalogiikalle ja koodille).
• Power Automate -virtaukset (liiketoimintaprosessien integrointiin).
• Teams-ilmoitukset (käyttäen pohjapohjaista viestintää).
• Sähköposti-ilmoitukset.

Kun sääntö aktivoituu, Aktivaattori lähettää tietoa tapahtuneesta ja jatkaa seurantaa odottamatta toiminnon valmistumista. Tämä lähestymistapa mahdollistaa skaalautuvat työnkulut, jotka voivat käsitellä useita tapahtumia samanaikaisesti.

Properties

Ominaisuudet ovat tietyn liiketoimintaobjektin kenttiä tai määritteitä, joita haluat valvoa. Ne voivat olla fyysisiä tai käsitteellisiä ominaisuuksia, kuten:

• Paketin lämpötila
• Lähetyksen tila
• Asiakastilin saldo
• Käyttäjäistunnon sitoutumispisteet

Ominaisuudet tulevat tapahtumavirroista, jotka ovat jatkuvia datavirtoja lähteistä kuten IoT-antureista, Power BI-raporteista tai muista järjestelmistä.

Kun määrität liiketoimintaobjektin Activatorissa, yhdistät yhden tai useamman tapahtumavirran, valitset objektitunnuksena käytettävän sarakkeen ja valitset muita sarakkeita, joita käsitellään kyseisen objektin ominaisuutena. Voit luoda näihin ominaisuuksiin sääntöjä, joiden avulla voit seurata ajan kuluessa tehtyjä muutoksia, tunnistaa, milloin ominaisuus ylittää kynnysarvon tai on alueen ulkopuolella, tai käynnistää toimintoja, kuten hälytyksiä, työnkulkuja tai ilmoituksia.

Ominaisuudet ovat hyödyllisiä myös silloin, kun haluat käyttää logiikkaa uudelleen useissa säännöissä. Esimerkiksi pakastinobjektissa voit määrittää ominaisuuden, joka laskee lämpötilan keskiarvon tunnin aikana. Kun ominaisuus on määritelty, voit viitata useisiin sääntöihin, kuten niihin, jotka havaitsevat ylikuumenemisen, lämpötilavaihtelut tai ylläpitokynnysarvot – ilman että logiikka kopioituu. Keskittämällä logiikan ominaisuuksiin teet säännöistä helpommin hallittavan, yhdenmukaisemman ja helpommin päivitettävän ajan kuluessa.

Katsaus

Lookback-jakso tarkoittaa historiallisten tietojen kestoa, jota Aktivaattori analysoi säännön arvioimiseksi. Se varmistaa, että aiempaa dataa on riittävästi kuvioiden tarkkaan tunnistamiseen tai aggregaatioiden, kuten keskiarvojen, laskemiseen, vaikka data saapuisi myöhässä tai epäsäännöllisesti.

Määrität takaisun katsausjakson seuraavasti:

• Miten määrittelet säännön, esimerkiksi vaatiiko se trendien analysointia, poikkeavuuksien havaitsemista vai arvojen vertailua ajan kuluessa.
• Saapuvan datan määrä, kuten tapahtumien määrä sekunnissa tapahtumavirrassa.

Harkitse lääkelogistiikkaoperaatiota, joka kuljettaa lääkepaketteja kylmässä ketjussa. Tavoitteena on saada ilmoitus, kun paketista tulee liian lämmin.

Oletetaan, että määrittelet säännön seuraavasti:

• Arvioi jokaisen paketin keskimääräinen lämpötila kolmen tunnin aikana
• Käynnistä ilmoitus, jos keskimääräinen lämpötila ylittää 8°C

Tämän säännön tarkkaan laskemiseksi Fabric Activatorin täytyy analysoida laajempi historiallinen tietoikkuna (esimerkiksi kuuden tunnin takaisun katselujakson kolmen tunnin keskiarvolle). Tämä prosessi varmistaa, että dataa on riittävästi kolmen tunnin keskiarvon laskemiseen milloin tahansa, vaikka tiedot saapuisivat jonkin verran viiveellä tai epäsäännöllisyydellä.

Paluujakso on välttämätön, jotta voit tunnistaa olosuhteet nopeasti ja tarkasti erityisesti tilanteissa, joissa tietomallit kehittyvät ajan mittaan.

Erilliset, aktiiviset objektitunnukset

Käytä attribuutteihin perustuvia sääntöjä seuraamaan, miten objektin tietyt attribuutit muuttuvat ajan myötä. Lääkelogistiikan esimerkissä kutakin lääkepakettia edustaa yksilöivä objektitunnus, ja järjestelmä vastaanottaa kausittaiset lämpötilalukemat kustakin paketista.

Näiden sääntöjen tehokkaaksi arvioimiseksi Fabric Activator seuraa aktiivisia objektitunnisteita – eli olioita, joiden tapahtumat saapuvat määritellyn katsausajan sisällä. Tämä käyttäytyminen varmistaa, että järjestelmä ottaa huomioon vain relevantit, tällä hetkellä aktiiviset objektit sääntöjä soveltaessa.

Esimerkiksi maksullinen asema voi seurata ajoneuvoja (objektitunnuksia) niiden kulkiessa läpi. Jokainen ajoneuvo tuottaa tapahtumia (esimerkiksi sisään- ja uloskäyntiskannaukset), ja järjestelmä arvioi vain ne kohteet, joilla on viimeaikaista toimintaa.

Myös erillisten objekti-ID:iden (pakettien määrä) määrä, joita seuraat lookback-ikkunassa, asettaa rajoituksia.

Yleiset käyttötapaukset

Tässä muutamia todellisia tilanteita, joissa voit käyttää Fabric Activatoria:

• Julkaise mainoskampanjoita automaattisesti, kun saman myymälän myynti heikkenee, mikä parantaa suorituskykyä sijaintien alisuoriutumisessa.
• Ilmoita ruokakaupan johtajille, että he siirtävät ruoan toimintahäiriöistä pakastimista, ennen kuin pilaantuminen tapahtuu.
• Käynnistä mukautettuja tiedotustyönkulkuja, kun asiakkaan matka sovellusten, sivustojen tai muiden kosketuspisteiden välillä osoittaa negatiivista kokemusta.
• Käynnistä tutkintaprosessit ennakoivasti, kun lähetyksen tilaa ei päivitetä määritellyn ajan kuluessa, mikä auttaa löytämään kadonneet paketit nopeammin.
• Hälytystilitiimit, kun asiakkaat joutuvat maksurästiin ja käyttävät mukautettuja aikakynnysarvoja tai avoimia saldoja asiakasta kohti.
• Valvo putken kuntoa ja suorita epäonnistuneet työt automaattisesti uudelleen tai ilmoita tiimeille, kun poikkeamia tai virheitä havaitaan.

Liittyvä sisältö

• Opas: Luo ja aktivoi Fabric Aktivaattorin sääntö
• Aktivaattorisääntöjen yleiskatsaus
• Trigger Fabric esineitä Aktivaattorisäännöstä
• Aktivointitoiminnon tunnistusehdot
• Aktivaattorin rajoitukset
• Luo varoitussääntö SQL-kyselylle
• Viive aktivaattorissa