Kombinera flera strömmar i en Aktiveringsregel

Den här artikeln visar hur du gör följande:

  • Övervaka data från flera händelseströmmar och automatisera åtgärder genom att definiera en Aktiveringsregel
  • Konfigurera flera avancerade villkor, till exempel genomsnittligt, maximalt eller lägsta värde för en dataegenskap, med hjälp av activator-modelleringsfunktioner.

Scenario

I det här exemplet kan du spåra hälsotillståndet för dina vattenpumpar (datorer) genom att övervaka maskinens flödeshastighet och vibrationer . Målet är att automatiskt vidta åtgärder, till exempel att skicka en avisering eller starta en affärsprocess, om vibrationer är onormala när datorn körs och flyttar en betydande mängd vatten (FlowRate). Högvattenpumpvibrationer kan signalera underliggande problem, men det förväntas så länge FlowRate är obetydligt.

Maskiner som övervakar dataflöden i två händelseströmmar:

  • MachineHeartbeat-händelseströmmen innehåller kolumnen MachineNumber som identifierar en dator och en MachineRunning-kolumn som anger om datorn körs (1) eller inte (0). En händelse genereras varje gång ett datortillstånd ändras.
  • MachineSensorsReadings eventstream innehåller en MachineId-kolumn tillsammans med kolumnerna FlowRate och Vibration . Varje dator avger sensoravläsningar med några sekunders mellanrum.

Observera att de två händelseströmmarna identifierar en dator med hjälp av olika kolumner: MachineId i MachineSensorsReadings och MachineNumber i MachineHeartbeat. Båda kolumnerna innehåller samma datoridentifierarvärden.

I det här scenariot vill du skapa en avisering när alla dessa villkor är uppfyllda:

  • Maximal vibration under de senaste 1 timme ökar över 18.
  • Genomsnittligt flödesflöde under de senaste 10 minuterna är över 185.
  • Datorn körs.

Regler för aktivering stöder komplexa villkor baserat på flera händelseströmmar. Du kan skapa beräknade egenskaper baserat på händelsekolumner och kombinera dem i regelvillkoret.

I det här scenariot sammanför du två eventstreams genom att skapa ett objekt som matar från båda strömmarna. När du lägger till en händelseström i objektet anger du vilken kolumn i händelserna som unikt identifierar instansen av ett objekt.

Note

Activator stöder anslutning av eventstreams som identifierar samma objekt med hjälp av olika unika identifierarkolumner. I det här scenariot använder MachineSensorsReadingsMachineId och MachineHeartbeat använder MachineNumber, och Activator kombinerar dem till ett enda objekt.

Sedan skapar du en egenskap som beräknar average(FlowRate), en annan för max(Vibration) och kombinerar dem med egenskapen IsRunning . När regeln utvärderas beräknar Activator egenskapsvärden enligt deras definitioner och underhåller det senaste beräknade värdet för varje egenskap. Dessa värden används när villkoret utvärderas.

I Regler för aktivering måste du ange ett Villkor, till exempel max(Vibration) > 18, och lägga till valfria filter, till exempel avg(FlowRate) > 185 AND MachineRunning. Regeln utlöses när villkoret uppfylls, förutsatt att filtren också är sanna.

Villkoret styr regeln enligt följande bild:

Skärmbild av ett diagram som visar hur villkoret styr regeln i Activator med filter och åtgärder.

Lösning

  1. Lägg till Activator-destination till båda händelseströmmarna. Kontrollera att båda eventstreams använder samma Activator-instans.

    Skärmbild av MachineHeartbeat-händelseströmmen med

    Skärmbild av MachineSensorsReadings eventstream med målet Activator tillagd.

    Båda händelseströmmarna konfigureras med samma Aktiveringsmål:

    Skärmbild av båda händelseströmmarna som konfigurerats med samma Aktiveringsmål.

  2. Öppna Aktivatorobjektet. Nu kan du kombinera båda eventstreams i ett objekt och konfigurera en regel.

    Skärmbild av objektet Activator som visar de två eventstreams som är tillgängliga att kombinera.

  3. Om du vill kombinera dessa två strömmar väljer du valfri ström och väljer Nytt objekt.

    Skärmbild av att välja en händelseström och klicka på knappen Nytt objekt.

  4. Välj det kolumnnamn som används för att identifiera instansen av ett objekt och kolumner som behövs för regeln och välj sedan Skapa. Värdet för kolumnen MachineId i varje händelse är nyckeln som identifierar den dator som genererat händelsen.

    Skärmbild av fönstret Skapa objekt med MachineId valt som unik identifierare och relevanta kolumner valda.

  5. Välj en annan händelseström, välj Nytt objekt och välj sedan Lägg till i befintligt objekt i fönstret Skapa objekt . Välj kolumnen MachineNumber som unik identifierare. Välj Tilldela. Nu kombineras de två strömmarna i ett objekt, även om varje dataström använder en annan identifierarkolumn.

    Skärmbild av fönstret Skapa objekt med alternativet Lägg till i befintligt objekt valt och MachineNumber som unik identifierare.

  6. Nu kan du definiera den beräknade egenskapen. Skapa ett attribut för beräkningsgenomsnittet för FlowRate under de senaste 10 minuter. Välj Attributet FlowRate och välj Redigera information.

    Skärmbild av att välja attributet FlowRate och klicka på Redigera information.

  7. I fönstret Definition väljer du Lägg till sammanfattning, väljer Genomsnitt och anger 10 minuter som fönsterstorlek. Välj Spara.

    Skärmbild av fönstret Definition med alternativet Lägg till sammanfattning och Medelvärde valt.

    Skärmbild av den genomsnittliga sammanfattningen som konfigurerats med en fönsterstorlek på 10 minuter.

  8. Välj Vibrationsattribut och välj Redigera information. I fönstret Definition väljer du Lägg till sammanfattning, väljer Max och anger 1 timme som fönsterstorlek. Välj Spara.

    Skärmbild av attributet Vibration med maximal sammanfattning konfigurerad för ett entimmesfönster.

  9. Skapa nu regeln. Välj Egenskapen Vibration och välj Ny regel.

    Skärmbild av att välja egenskapen Vibration och klicka på knappen Ny regel.

  10. I fönstret Definitionkonfigurerar du Ökningar över villkoret med 18 som tröskelvärde.

    Skärmbild av Definition-fönstret med villkoret Ökning vid villkor ovan inställt på tröskelvärdet 18.

  11. Lägg till ett filter för egenskapen FlowRate och ett för egenskapen MachineRunning .

    Skärmbild av regeln med filter som lagts till för egenskaperna FlowRate och MachineRunning.

  12. Välj en åtgärd som du väljer som att skicka e-post eller Teams-meddelanden, köra affärsprocesser som pipeline, notebook-fil eller funktioner eller köra anpassad åtgärd utan kod med Power Automate. Välj Spara och starta.

    Skärmbild av sidan för åtgärdsval med alternativ för att skicka meddelanden eller köra affärsprocesser.

Nästa steg

Mer information om Aktiveringsregler finns i Skapa och hantera aktiveringsregler.