Mikä on Fabric Activator? Tietovirtojen muuntaminen automatisoiduiksi toiminnoiksi

Fabric Activator on koodittomuus ja pienen viiveen tunnistusmoduuli, joka käynnistää automaattisesti toiminnot, kun tietolähteistä havaitaan tiettyjä malleja tai ehtoja. Tärkeimpiä ominaisuuksia ovat seuraavat:

Se valvoo jatkuvasti näitä tietolähteitä alisekunnin viiveellä ja käynnistää toiminnot, kun raja-arvot täyttyvät tai kun tiettyjä kuvioita havaitaan. Näitä toimintoja voivat olla sähköpostien tai Teams-ilmoitusten lähettäminen, Power Automate -työnkulkujen käynnistäminen tai integrointi kolmannen osapuolen järjestelmiin.

Ydinarkkitehtuuri

Activator on tapahtuman havaitsemisen ja sääntöjen moottori Fabric Real-Time intelligence stackin 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 tapahtumapohjaiseen, reagoivaan arkkitehtuuriin, jossa tietovuo kulkee jatkuvasti, ja päätöksiä tehdään tapahtumatietojen tilallisten arviointien perusteella lähes reaaliaikaisesti.

• Tapahtumien lähteet

  Activator muodostaa yhteyden suoraan tapahtumatoimintoihin, jotka käyttävät eri tuottajien tietoja (Azure-tapahtumatoiminnot, IoT-laitteet, mukautettu päätepiste jne.). Nämä tietovirrat toimivat tapahtumien lähteenä, ja Activator voi tilata yhden tai useamman tapahtumavirran tietojen muutosten seuraamiseksi. Muita tapahtumalähteitä voivat olla Fabric- tai Azure-tapahtumat tai Power BI -raporttia kuunteleva aktivoija tai Real-Time koontinäyttö.

• Tapahtumat ja objektit

  Tapahtumat ovat yksittäisiä tietueita (esimerkiksi telemetriasignaali tai tiedoston pudotus), jotka on vastaanotettu eventstreamin kautta. Nämä tapahtumat on ryhmitelty objekteihin jaetun tunnisteen perusteella (esimerkiksi bikepoint_id, device_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 tilallisia lausekkeita, kuten BECOMES, DECREASES, INCREASES, EXIT RANGEtai tietojen (sykkeen) puuttuminen. 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 tai kipinätyön määritystä Fabricissa.

    • Ulkoiset toiminnot Power Automaten kautta.
    • Teams-viestin lähettäminen henkilölle, ryhmälle tai kanavalle
    • Lähetä sähköpostia

• Hälytysten 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. Aktivointiesiintymät on rajoitettu Fabric-kapasiteetteihin, ja niitä voidaan valvoa työtilan kautta. Suorituksenaikaiset lokit ja telemetriatiedot ovat käytettävissä tapahtumavirkojen ja putkitulosteiden kautta.

Käyttöönottomalli

Aktivointiesiintymät otetaan käyttöön työtilaa kohden ja sidotaan tiettyihin tietolähteisiin. Useat aktivoijat voivat valvoa samaa tietovirtaa ja ottaa käyttöön rinnakkaiset sääntöarvioinnit eri liiketoimintafunktioille. Koska aktivaattori on sidottu kapasiteettiin, käytön mukaan laskuteltavien hinnoittelujen hinnoittelu on voimassa vain silloin, kun säännöt ovat aktiivisessa toiminnassa. Tämä parantaa ajoittaisten tunnistusskenaarioiden kustannustehokkuutta.

Real-Time-älyn integrointipisteet

Component	Aktivaattorin käsittely
Eventstream	Se toimittaa yhdistettyjä tietoja Activatoriin pienen viiveen virran käsittelyllä.
Activator	Voi luoda tapahtumia (esimerkiksi täydennettyjä entiteettejä tai johdettuja otsikoita), jotka käynnistävät toisen aktivoijan.
Pipeline	Activatorin säännön käynnistimien kohde, joka automatisoi jatkokäsittelyn
Power BI	Kuluttaa käynnistettyjen jaksojen tai muistikirjojen tuloksia reaaliaikaisia visualisointeja varten
Power Automate	Mahdollistaa tapahtumapohjaiset toiminnot mallipohjaisten tai mukautettujen toimintojen avulla
Fabric-tapahtumat	Se tarjoaa Fabric-tapahtumia, kuten semanttisen mallin päivittämisen tai putken epäonnistumisen.
Notebooks	Muistikirja voidaan käynnistää aktivoijalla

Välittäjän aktivaattori

Activatorin tehokas käyttö suuryritystason reaaliaikaisissa arkkitehtuualeissa edellyttää tarkoituksellista orkestrointia Microsoft Fabric -komponenteissa ja suorituskyvyn säätöä tapahtumien määrän, objektien kardinaliteetin ja sääntöjen monimutkaisuuden osalta. Tässä osiossa tutustutaan siihen, miten activator orkesoidaan muilla palveluilla ja miten tunnistuslogiikka ja suorituksenaikainen käyttäytyminen optimoidaan pienen viiveen ja kustannustehokkaan automaation tukemiseksi mittakaavassa.

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

Pattern	Työnkulun kuvaus
Tietojen käsittely → havaitseminen → muunnos	Tapahtumat kulkevat Eventstreamista aktivaattoriin, joka käynnistää putken tietojen rikastamiseksi tai siirtämiseksi.
Tietojen käsittely → havaitseminen → ilmoitus	Aktivointi käynnistää Power Automaten, joka lähettää ilmoituksia tai lähettää tilan Teamsiin, Outlookiin tai ServiceNow'hin.
Tietojen käsittely → havaitseminen → mallin pisteytys	Activator käynnistää muistikirjan koneoppimismallin pisteyttämiseksi tai kehittyneen analytiikan suorittamiseksi reaaliaikaisten poikkeamien perusteella.
Palautesilmukka, jossa on aktivointi (suunniteltu)	Aktivoijan luomat merkitykselliset tiedot (esimerkiksi luottamuksellisuustunnisteet) syötetään Activator-sääntöihin, mikä mahdollistaa semanttisesti täydennettyjen automaatioiden käyttöönoton.

Keskeiset käsitteet

Microsoft Fabric Activator toimii suorituskykyisenä, osavaltiota huomioon ottavata sääntömoduulina, joka on suunniteltu suoratoistotapahtumien pienen viiveen arviointiin. Activator käsittelee ytimessä tapahtumavirran kautta lähetykset reaaliaikaiset tapahtumat, arvioi sääntöehdot loogista objektia kohden ja käynnistää jatkokäsittelytoiminnot vastauksena tilan siirtymiä. Saat yleiskatsauksen Fabric-aktivaattorista artikkelista Fabric-aktivointitoiminnon esittely.

Seuraavien käsitteiden avulla luodaan ja käynnistetään 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äpuolisia lähteitä (esimerkiksi Azure-tapahtumatoiminnot, IoT-keskitin, Blob-säilön käynnistimet). Eventstream on tietty kohdetyyppi Microsoft Fabricissa, joten voit käyttää, muuntaa ja reitittää reaaliaikaisia tapahtumia kirjoittamatta koodia. Fabric Activator valvoo tapahtumavirtaa ja ryhtyy automaattisesti toimiin, kun määritettyjä malleja tai raja-arvoja 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.
• Kangas tapahtumat. Esimerkiksi Fabric-työtilan kohdetapahtumat 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.
• Azure-tapahtumat. Esimerkiksi Azure Blob -säilön tapahtumat käynnistyvät, kun asiakas luo, korvaa, poistaa blob-objektin jne.
• Power BI -raportti. Tässä tapauksessa tapahtumat ovat säännöllisiä havaintoja Power BI:n semanttisen mallin (aiemmalta nimeltään tietojoukko) päivitysaikataulusta. Nämä havainnot saattavat tapahtua päivittäin tai viikoittain, mikä muodostaa hitaasti etenevän tapahtumavirran.
• Fabric Real-Time -koontinäyttö.

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 valvovia 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ä objektia kohden (esimerkiksi arvo VÄHENEE, TULEE, POISTUMISALUE)

Tilallinen arviointi perustuu:

• Delta-tunnistus: Seuraa aiempien ja nykyisten tapahtuma-arvojen välisiä muutoksia.
• Ajallinen sekvensointi: Arvioi aikaperusteisia olosuhteita, kuten tapahtumien puuttumista (sykkeen tunnistus)
• Tilasiirtymät: Säännöt laukeavat vain uuteen tilaan tullessa, mikä estää toistuvat ampumiset muuttumattomissa olosuhteissa

Jokainen säännön ehto on koottu suorituskaavioksi, jota arvioidaan jatkuvasti, muistissa ja lähes välittömästi. Järjestelmä on optimoitu alisekunnin päätöksenteon viivettä varten tapahtuman saapumisen jälkeen.

Actions

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

• Kangasputket (tietojen siirtoon, rikastamiseen)
• Kangasmuistikirjat (koneoppimisen pisteytykseen, diagnostiikkaan)
• Power Automaten työnkulut (liiketoimintaprosessin integrointiin)
• Teams-ilmoitukset (mallipohjaisten viestien avulla)

Activator lähettää käynnistinviestin, joka sisältää nykyisen objektin tilan ja säännön metatiedot. Toiminnot eivät ole estotilassa. Aktivaattori ei siis odota, kunnes skaalattavat asynkroniset työnkulut otetaan käyttöön toimintojen valmistumisen jälkeen.

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

Ne on saatu tapahtumavirroista, jotka ovat jatkuvia tietovirtoja lähteistä, kuten IoT-tunnistimista, 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. Määritettynä tähän ominaisuuteen voidaan viitata useissa säännöissä, kuten säännöissä, jotka havaitsevat ylikuumenemisen, lämpötilan vaihtelut tai ylläpitokynnysarvot – monistamatta logiikkaa. Keskittämällä logiikan ominaisuuksiin teet säännöistä helpommin hallittavan, yhdenmukaisemman ja helpommin päivitettävän ajan kuluessa.

Katsaus

Hakujakso viittaa niiden historiallisten tietojen kestoon, joita Activator analysoi säännön arvioimiseksi. Se varmistaa, että saatavilla on riittävästi aiempia tietoja, jotta se voi tunnistaa tarkasti toistuvuuksia tai käsittelykoosteita, kuten keskiarvoja, vaikka tietoja saavutettaisiin myöhään tai epäsäännöllisesti.

Hakujakso määräytyy seuraavasti:

• Miten sääntö määritetään, esimerkiksi edellyttääkö se trendien analysointia, poikkeamien havaitsemista tai arvojen vertaamista ajan kuluessa.
• Saapuvien tietojen 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ä sääntö on määritetty 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

Jotta tämä sääntö voidaan laskea tarkasti, Fabric Activatorin on analysoitava laajempi aikaväli historiallisista tiedoista, erityisesti kuuden tunnin hakujakso. Se varmistaa, että käytettävissä on riittävästi tietoja kolmen tunnin keskiarvon laskemiseen milloin tahansa, vaikka tietoja tulisikin viiveellä tai epäsäännöllisyyksillä.

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

Määritteisiin perustuvien sääntöjen avulla valvotaan, miten objektin tietyt määritteet muuttuvat ajan kuluessa. Lääkelogistiikan esimerkissä kutakin lääkepakettia edustaa yksilöivä objektitunnus, ja järjestelmä vastaanottaa kausittaiset lämpötilalukemat kustakin paketista.

Jotta nämä säännöt voidaan arvioida tehokkaasti, Fabric-aktivointi seuraa aktiivisia objektitunnuksia eli objekteja, joille tapahtumat saapuvat määritetyn hakujakson aikana. Tämä varmistaa, että sääntöjä käytettäessä otetaan huomioon vain olennaiset, aktiiviset objektit.

Esimerkiksi maksullinen asema voi seurata ajoneuvoja (objektitunnuksia) niiden kulkiessa läpi. Jokainen ajoneuvo luo tapahtumia (esimerkiksi luku- ja poistumisskanneita), ja järjestelmä pitää vain niitä objekteja, joiden toiminta on viimeisintä, aktiivisena ja arvioi ne.

Rajoituksia on myös sen mukaan, kuinka monta erillistä objektitunnusta (pakettien määrä) jäljitetään hakuikkunassa.

Yleiset käyttötapaukset

Seuraavassa on muutamia reaalimaailman skenaarioita, joissa voit käyttää Fabric-aktivointitoimintoa:

• 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.
• Aloita ennakoivasti tutkimustyönkulut, kun lähetyksen tilaa ei päivitetty määritetyn ajanjakson aikana, mikä auttaa etsimään kadonneita paketteja 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.

Seuraava vaihe

Katso opetusohjelma: Fabric-aktivointisäännön luominen ja aktivoiminen.