Sådan kombinerer du flere strømme i en Activator-regel

I denne artikel lærer du, hvordan du kan:

  • Overvåg data fra flere hændelsesstrømme og automatiser handlinger ved at definere en Aktivator-regel
  • Opsæt flere avancerede betingelser, såsom gennemsnitlig, maksimums- eller minimumsværdi af en dataegenskab, ved at bruge Activator-modelleringsmuligheder.

Scenarie

I dette eksempel kan du spore tilstanden af dine vandpumper (maskiner) ved at overvåge maskinens flowhastighed og vibration . Målet er automatisk at tage handling, såsom at sende en advarsel eller starte en forretningsproces, hvis vibrationerne er unormale, mens maskinen kører og flytter betydelige mængder vand (flowRate). Høje vibrationer i vandpumpen kan indikere underliggende problemer, men det forventes, så længe flowhastigheden er ubetydelig.

Maskiner, der overvåger data, flyder ind i to hændelsesstrømme:

  • MachineHeartbeat-hændelsesstrømmen indeholder kolonnen MachineNumber, der identificerer en maskine, og kolonnen MachineRunning , der angiver, om maskinen kører (1) eller ej (0). En hændelse udsendes hver gang en maskintilstand ændres.
  • MachineSensorsReadings eventstream indeholder en MachineId-kolonne sammen med FlowRate- og Vibration-kolonnerne. Hver maskine udsender sensoraflæsninger hvert par sekunder.

Bemærk, at de to hændelsesstrømme identificerer en maskine ved at bruge forskellige kolonner: MachineId i MachineSensorsReadings og MachineNumber i MachineHeartbeat. Begge kolonner indeholder de samme maskinidentifikatorværdier.

I dette scenarie vil du udløse en advarsel, når alle disse betingelser er opfyldt:

  • Maksimal vibration i den sidste time stiger over 18.
  • Den gennemsnitlige flowhastighed i de sidste 10 minutter er over 185.
  • Maskinen kører.

Aktivatorregler understøtter komplekse betingelser baseret på flere hændelsesstrømme. Du kan oprette beregnede egenskaber baseret på hændelseskolonner og kombinere dem i regelbetingelsen.

I dette scenarie bringer du to hændelsesstrømme sammen ved at skabe et objekt , der feeder fra begge strømme. Når du tilføjer en eventstream til objektet, angiver du, hvilken kolonne i begivenhederne der entydigt identificerer instansen af et objekt.

Bemærk

Activator understøtter at sammenflette hændelsesstrømme, der identificerer det samme objekt, ved at bruge forskellige unikke identifikatorkolonner. I dette scenarie bruger MachineSensorsReadingsMachineId , og MachineHeartbeat bruger MachineNumber, og Activator kombinerer dem til ét objekt.

Derefter opretter du en egenskab, der beregner gennemsnit (FlowRate), en anden for max(Vibration), og kombinerer dem med IsRunning-egenskaben . Når reglen evalueres, beregner Activator egenskabsværdier i henhold til deres definitioner og opretholder den sidst beregnede værdi af hver egenskab. Disse værdier anvendes ved evaluering af tilstanden.

I Activator-regler skal du sætte én betingelse, såsom max(Vibration) > 18, og tilføje valgfrie filtre, såsom avg(FlowRate) > 185 OG MachineRunning. Reglen aktiveres, når betingelsen er opfyldt, forudsat at filtrene også er sande.

Betingelsen styrer reglen, som illustreret i følgende billede:

Skærmbillede af et diagram, der viser, hvordan tilstanden styrer reglen i Activator med filtre og handlinger.

Løsning

  1. Tilføj Activator-destination til begge eventstreams. Sørg for, at begge eventstreams bruger den samme Activator-instans.

    Skærmbillede af MachineHeartbeat-begivenhedsstrømmen med Activator-destinationen tilføjet.

    Skærmbillede af MachineSensorsReadings-begivenhedsstrømmen med Activator-destinationen tilføjet.

    Begge hændelsesstrømme er konfigureret med samme Activator-destination:

    Skærmbillede af begge eventstreams konfigureret med samme Activator-destination.

  2. Åbn Activator-genstand. Nu kan du kombinere begge hændelsesstrømme i et objekt og opsætte en regel.

    Skærmbillede af Activator-elementet, der viser de to eventstreams, der kan kombineres.

  3. For at kombinere disse to strømme skal du vælge en hvilken som helst strøm og vælge Nyt objekt.

    Skærmbillede af at vælge en eventstream og klikke på knappen Nyt objekt.

  4. Vælg kolonnenavnet, der bruges til at identificere den instans af et objekt og kolonner, der er nødvendige for reglen, og vælg derefter Create. Værdien af MachineId-kolonnen i hver hændelse er nøglen, der identificerer den maskine, der udsendte hændelsen.

    Skærmbillede af Build-objektpanelet med MachineId valgt som unik identifikator og relevante kolonner valgt.

  5. Vælg en anden eventstream, vælg Nyt objekt, og vælg derefter Add to existing object i Build object-panelet . Vælg kolonnen MachineNumber som unik identifikator. Vælg Tildel. Nu kombineres de to strømme i ét objekt, selvom hver strøm bruger en forskellig identifikatorkolonne.

    Skærmbillede af byg-objekt-panelet med muligheden Tilføj til eksisterende objekt valgt og MachineNumber som den unikke identifikator.

  6. Nu kan du definere den beregnede egenskab. Opret en attribut til at beregne gennemsnittet af FlowRate i de sidste 10 minutter. Vælg FlowRate-attributten og vælg Rediger detaljer.

    Skærmbillede af at vælge FlowRate-attributten og klikke på Rediger detaljer.

  7. I definitionspanelet vælger du Tilføj opsummering, vælg Gennemsnit, og sæt 10 minutter som vinduesstørrelse. Vælg Gem.

    Skærmbillede af definitionspanelet med mulighed Tilføj opsummering og Gennemsnit valgt.

    Skærmbillede af Average Summarization konfigureret med et 10-minutters vinduesformat.

  8. Vælg Vibration-attributten og vælg Rediger detaljer. I definitionspanelet vælger du Tilføj opsummering, vælg Maksimum, og sæt 1 time som vinduesstørrelse. Vælg Gem.

    Skærmbillede af Vibration-attributten med Maximum summarization konfigureret til et vindue på én time.

  9. Lav nu reglen. Vælg Vibration-egenskaben og vælg Ny regel.

    Skærmbillede af at vælge Vibration-egenskaben og klikke på knappen Ny Regel.

  10. I definitionspanelet opsætter du Stigninger over betingelsen med 18 som tærskel.

    Skærmbillede af definitionspanelet med betingelsen Stigninger ovenfor sat til tærskelværdien 18.

  11. Tilføj et filter for FlowRate-egenskaben og et for MachineRunning-egenskaben .

    Skærmbillede af reglen med filtre tilføjet til FlowRate- og MachineRunning-egenskaberne.

  12. Vælg en handling efter eget valg, som at sende e-mail eller Teams-beskeder, køre forretningsprocesser som pipeline, notesbog eller funktioner, eller køre no-code brugerdefineret handling med Power Automate. Vælg Gem og start.

    Skærmbillede af handlingsvalgssiden med muligheder for at sende notifikationer eller køre forretningsprocesser.

Næste trin

For at lære mere om Activator-regler, se Opret og administrer Activator-regler.