Meerdere stromen combineren in een Activator-regel

In dit artikel leest u hoe u het volgende kunt doen:

  • Gegevens van meerdere eventstreams bewaken en acties automatiseren door een Activator-regel te definiëren
  • Stel meerdere geavanceerde voorwaarden in, zoals gemiddelde, maximum of minimumwaarde van een gegevenseigenschap, met behulp van activatormodelleringsmogelijkheden.

Scenario

In dit voorbeeld kunt u de status van uw waterpompen (machines) bijhouden door de stroomsnelheid en trillingen van de machine te bewaken. Het doel is om automatisch actie te ondernemen, zoals het verzenden van een waarschuwing of het starten van een bedrijfsproces, als de trillingen abnormaal zijn terwijl de machine in bedrijf is en een aanzienlijke hoeveelheid water (FlowRate) verplaatst. Hoge waterpomptrillingen kunnen onderliggende problemen signaleren, maar het wordt verwacht zolang FlowRate onbelangrijk is.

Machines die gegevensstromen bewaken, splitsen deze in twee gebeurtenisstromen.

  • MachineHeartbeat-eventstream bevat de kolom MachineNumber, die een machine identificeert, en de kolom MachineRunning, die aangeeft of de machine draait (1) of niet (0). Er wordt een gebeurtenis verzonden telkens wanneer de status van een machine wordt gewijzigd.
  • MachineSensorsReadings eventstream bevat een MachineId-kolom samen met kolommen FlowRate en Vibration . Elke machine emiteert sensorwaarden elke paar seconden.

U ziet dat de twee eventstreams een machine identificeren met behulp van verschillende kolommen: MachineId in MachineSensorsReadings en MachineNumber in MachineHeartbeat. Beide kolommen bevatten dezelfde machine-id-waarden.

In dit scenario wilt u een waarschuwing genereren wanneer aan al deze voorwaarden wordt voldaan:

  • De maximumtrilling in het afgelopen 1 uur neemt toe boven de 18.
  • De gemiddelde stroomsnelheid in de afgelopen 10 minuten is hoger dan 185.
  • De machine draait.

Activatorregels ondersteunen complexe voorwaarden op basis van meerdere eventstreams. U kunt berekende eigenschappen maken op basis van gebeurteniskolommen en deze combineren in de regelvoorwaarde.

In dit scenario brengt u twee gebeurtenisstromen samen door een object te maken dat vanuit beide streams wordt ingevoerd. Wanneer u een eventstream aan het object toevoegt, geeft u op welke kolom in de gebeurtenissen het exemplaar van een object uniek identificeert.

Note

Activator ondersteunt het samenvoegen van eventstreams die hetzelfde object identificeren met behulp van verschillende unieke id-kolommen. In dit scenario maakt MachineSensorsReadings gebruik van MachineId en MachineHeartbeat maakt gebruik van MachineNumber. Activator combineert deze in één object.

Vervolgens maakt u een eigenschap waarmee gemiddelde (FlowRate), een andere eigenschap wordt berekend voor max(Vibration) en deze combineert met de eigenschap IsRunning . Bij het evalueren van de regel berekent Activator eigenschapswaarden op basis van hun definities en onderhoudt de laatst berekende waarde van elke eigenschap. Deze waarden worden gebruikt bij het evalueren van de voorwaarde.

In Activator-regels moet u één voorwaarde instellen, zoals max(Vibration) > 18 en optionele filters toevoegen, zoals avg(FlowRate) > 185 AND MachineRunning. De regel wordt geactiveerd wanneer aan de voorwaarde wordt voldaan, op voorwaarde dat de filters ook waar zijn.

De voorwaarde bepaalt de regel zoals geïllustreerd in de volgende afbeelding:

Schermopname van een diagram waarin wordt getoond hoe de voorwaarde de regel in Activator aanstuurt met filters en acties.

Solution

  1. Voeg activatorbestemming toe aan beide eventstreams. Zorg ervoor dat beide eventstreams hetzelfde Activator-exemplaar gebruiken.

    Schermopname van de MachineHeartbeat-gebeurtenisstream met de Activator-bestemming toegevoegd.

    Schermopname van de Gebeurtenisstream MachineSensorsReadings met de Activator-bestemming toegevoegd.

    Beide eventstreams zijn geconfigureerd met dezelfde Activator-bestemming:

    Schermopname van beide eventstreams die zijn geconfigureerd met dezelfde Activator-bestemming.

  2. Open Activator-item. U kunt nu beide eventstreams in een object combineren en een regel instellen.

    Schermopname van het Activator-item met de twee gebeurtenisstromen die beschikbaar zijn om te combineren.

  3. Als u deze twee streams wilt combineren, selecteert u een stream en selecteert u Nieuw object.

    Schermopname van het selecteren van een eventstream en het klikken op de knop Nieuw object.

  4. Selecteer de kolomnaam die wordt gebruikt om het exemplaar van een object en kolommen te identificeren dat nodig is voor de regel en selecteer vervolgens Maken. De waarde van de kolom MachineId in elke gebeurtenis is de sleutel waarmee de machine wordt geïdentificeerd die de gebeurtenis heeft verzonden.

    Schermopname van het deelvenster Object bouwen met MachineId geselecteerd als de unieke id en relevante kolommen geselecteerd.

  5. Selecteer een andere gebeurtenisstroom, selecteer Nieuw object en selecteer vervolgens Toevoegen aan bestaand object in het deelvenster Object bouwen . Kies de kolom MachineNumber als unieke id. Selecteer Toewijzen. Nu worden de twee streams gecombineerd in één object, ook al gebruikt elke stroom een andere id-kolom.

    Schermopname van het deelvenster Object maken met Toevoegen aan bestaande objectoptie geselecteerd en MachineNumber als de unieke id.

  6. U kunt nu de berekende eigenschap definiëren. Maak een kenmerk voor het berekenen van het gemiddelde van FlowRate in de afgelopen 10 minuten. Selecteer het kenmerk FlowRate en selecteer Details bewerken.

    Schermopname van het selecteren van het kenmerk FlowRate en het klikken op Details bewerken.

  7. Selecteer samenvatting toevoegen in het deelvenster Definitie, kies Gemiddelde en stel 10 minuten in als venstergrootte. Selecteer Opslaan.

    Schermopname van het deelvenster Definitie met de optie Samenvatting toevoegen en Gemiddelde geselecteerd.

    Schermopname van de gemiddelde samenvatting die is geconfigureerd met een venstergrootte van 10 minuten.

  8. Selecteer het kenmerk Trillingen en selecteer Details bewerken. Selecteer in het deelvenster Definitiede optie Samenvatting toevoegen, kies Maximum en stel 1 uur in als venstergrootte. Selecteer Opslaan.

    Schermopname van het kenmerk Vibration met Maximumsamenvatting geconfigureerd voor een venster van één uur.

  9. Maak nu de regel. Selecteer de eigenschap Trillingen en selecteer Nieuwe regel.

    Schermopname van het selecteren van de eigenschap Trillingen en het klikken op de knop Nieuwe regel.

  10. Stel in het deelvenster Definitie, de voorwaarde Verhogen boven in met 18 als drempelwaarde.

    Schermopname van het deelvenster Definitie met de voorwaarde Verhogen boven ingesteld op drempelwaarde van 18.

  11. Voeg een filter toe voor de eigenschap FlowRate en een voor de eigenschap MachineRunning .

    Schermopname van de regel met filters toegevoegd voor de eigenschappen FlowRate en MachineRunning.

  12. Selecteer een actie van uw keuze, zoals het verzenden van e-mail of Teams-berichten, het uitvoeren van bedrijfsproces zoals pijplijn, notebook of functies, of het uitvoeren van aangepaste actie zonder code met Power Automate. Selecteer Opslaan en starten.

    Schermopname van de actieselectiepagina met opties voor het verzenden van meldingen of het uitvoeren van bedrijfsprocessen.

Volgende stap

Zie Activator-regels maken en beheren voor meer informatie over Activator-regels.

  • Last updated on