Wie man mehrere Datenströme in einer Aktivatorregel kombiniert

Dieser Artikel zeigt Ihnen, wie das geht:

  • Überwachen von Daten aus mehreren Ereignisstreams und Automatisieren von Aktionen durch Definieren einer Aktivatorregel
  • Richten Sie mehrere erweiterte Bedingungen ein, z. B. mittelwert, maximal oder minimaler Wert einer Dateneigenschaft, mithilfe von Aktivierermodellierungsfunktionen.

Scenario

In diesem Beispiel können Sie die Integrität Ihrer Wasserpumpen (Maschinen) nachverfolgen, indem Sie die FlowRate und Vibration der Maschine überwachen. Das Ziel besteht darin, automatisch Maßnahmen zu ergreifen, z. B. das Senden einer Warnung oder das Starten eines Geschäftsprozesses, wenn die Vibration ungewöhnlich ist, während die Maschine läuft und eine erhebliche Menge Wasser (FlowRate) bewegt. Hohe Wasserkreiselpumpen-Vibration kann auf zugrunde liegende Probleme hinweisen, ist jedoch akzeptabel, solange die Durchflussrate unbedeutend ist.

Computer, die Daten überwachen, fließen in zwei Ereignisstreams:

  • Der MachineHeartbeat-Ereignisstream enthält die MachineNumber-Spalte , die einen Computer und eine MachineRunning-Spalte identifiziert, die angibt, ob der Computer ausgeführt wird (1) oder nicht (0). Jedes Mal, wenn sich ein Computerzustand ändert, wird ein Ereignis ausgegeben.
  • MachineSensorsReadings-Ereignisstream enthält eine MachineId-Spalte zusammen mit FlowRate - und Vibration-Spalten . Jede Maschine übermittelt Sensordaten alle paar Sekunden.

Beachten Sie, dass die beiden Ereignisstreams einen Computer mithilfe verschiedener Spalten identifizieren: MachineId in MachineSensorsReadings und MachineNumber in MachineHeartbeat. Beide Spalten enthalten dieselben Computerbezeichnerwerte.

In diesem Szenario möchten Sie eine Warnung auslösen, wenn alle diese Bedingungen erfüllt sind:

  • Die maximale Vibration in den letzten 1 Stunden erhöht sich über 18.
  • Die durchschnittliche FlowRate in den letzten 10 Minuten liegt über 185.
  • Die Maschine läuft.

Aktivierregeln unterstützen komplexe Bedingungen basierend auf mehreren Ereignisstreams. Sie können berechnete Eigenschaften basierend auf Ereignisspalten erstellen und in der Regelbedingung kombinieren.

In diesem Szenario bringen Sie zwei Ereignisströme zusammen, indem Sie ein Objekt erstellen, das sich aus beiden Strömen speist. Wenn Sie dem Objekt einen Ereignisstream hinzufügen, geben Sie an, welche Spalte in den Ereignissen die Instanz eines Objekts eindeutig identifiziert.

Note

Aktivator unterstützt das Verknüpfen von Ereignisstreams, die dasselbe Objekt mithilfe verschiedener eindeutiger Bezeichnerspalten identifizieren. In diesem Szenario verwendet MachineSensorsReadingsMachineId und MachineHeartbeat verwendet MachineNumber, und Activator kombiniert beide zu einem einzigen Objekt.

Anschließend erstellen Sie eine Eigenschaft, die mittelwert(FlowRate), eine weitere für max(Vibration) berechnet, und kombinieren sie mit der IsRunning-Eigenschaft . Beim Auswerten der Regel berechnet Activator Eigenschaftswerte basierend auf ihren Definitionen und verwaltet den letzten berechneten Wert für jede Eigenschaft. Diese Werte werden beim Auswerten der Bedingung verwendet.

In Aktivierregeln müssen Sie eine Bedingung festlegen, z. B. max(Vibration) > 18, und optionale Filter wie avg(FlowRate) > 185 AND MachineRunning hinzufügen. Die Regel wird ausgelöst, wenn die Bedingung erfüllt ist, sofern auch die Filter zutreffen.

Die Bedingung steuert die Regel wie in der folgenden Abbildung dargestellt:

Screenshot eines Diagramms, das zeigt, wie die Bedingung die Regel im Aktivator mit Filtern und Aktionen steuert.

Lösung

  1. Fügen Sie das Aktivatorziel zu beiden Eventstreams hinzu. Stellen Sie sicher, dass beide Ereignisstreams dieselbe Aktivatorinstanz verwenden.

    Screenshot des MachineHeartbeat-Ereignisstreams mit dem hinzugefügten Aktivatorziel.

    Screenshot des MachineSensorsReadings-Ereignisstreams mit dem hinzugefügten Aktivatorziel.

    Beide Ereignisstreams sind mit demselben Aktivatorziel konfiguriert:

    Screenshot der beiden Ereignisstreams, die mit demselben Aktivatorziel konfiguriert sind.

  2. Öffnen Sie das Aktivatorelement. Jetzt können Sie beide Ereignisstreams in einem Objekt kombinieren und eine Regel einrichten.

    Screenshot des Aktivatorelements mit den beiden für die Kombination verfügbaren Ereignisstreams.

  3. Um diese beiden Datenströme zu kombinieren, wählen Sie einen beliebigen Datenstrom aus, und wählen Sie "Neues Objekt" aus.

    Screenshot der Auswahl eines Ereignisstreams und Klicken auf die Schaltfläche

  4. Wählen Sie den Spaltennamen aus, der verwendet wird, um die Instanz eines Objekts und spalten zu identifizieren, die für die Regel erforderlich sind, und wählen Sie dann "Erstellen" aus. Der Wert der MachineId-Spalte in jedem Ereignis ist der Schlüssel, der den Computer identifiziert, der das Ereignis ausgegeben hat.

    Screenshot des Bereichs

  5. Wählen Sie einen anderen Eventstream aus, wählen Sie "Neues Objekt" und dann im Bereich "Objekt erstellen" die Option "Zu vorhandenem Objekt hinzufügen" aus. Wählen Sie die MachineNumber-Spalte als eindeutigen Bezeichner aus. Wählen Sie Zuweisen aus. Jetzt werden die beiden Datenströme in einem Objekt kombiniert, obwohl jeder Datenstrom eine andere Bezeichnerspalte verwendet.

    Screenshot des Bereichs

  6. Jetzt können Sie die berechnete Eigenschaft definieren. Erstellen Sie ein Attribut zum Berechnen des Mittelwerts von FlowRate in den letzten 10 Minuten. Wählen Sie "FlowRate "-Attribut und dann "Details bearbeiten" aus.

    Screenshot der Auswahl des FlowRate-Attributs und Klicken auf

  7. Wählen Sie im Bereich "Definition " die Option " Zusammenfassung hinzufügen", wählen Sie "Mittelwert" aus, und legen Sie 10 Minuten als Fenstergröße fest. Wählen Sie Speichern aus.

    Screenshot des Bereichs

    Screenshot der durchschnittlichen Zusammenfassung, die mit einer Fenstergröße von 10 Minuten konfiguriert ist.

  8. Wählen Sie "Vibration "-Attribut und dann "Details bearbeiten" aus. Wählen Sie im Bereich "Definition " die Option " Zusammenfassung hinzufügen", dann " Maximum" aus, und legen Sie "1 Stunde" als Fenstergröße fest. Wählen Sie Speichern aus.

    Screenshot des Vibrations-Attributs mit maximaler Zusammenfassung, die für ein Einstündiges Fenster konfiguriert ist.

  9. Erstellen Sie nun die Regel. Wählen Sie "Vibration "-Eigenschaft und dann "Neue Regel" aus.

    Screenshot der Auswahl der Vibrationseigenschaft und Klicken auf die Schaltfläche

  10. Richten Sie im Definitionsbereich die Bedingung „Anstieg über“ ein, und verwenden Sie 18 als Schwellenwert.

    Screenshot des Bereichs

  11. Fügen Sie einen Filter für die FlowRate-Eigenschaft und eine für die MachineRunning-Eigenschaft hinzu .

    Screenshot der Regel mit hinzugefügten Filtern für flowRate- und MachineRunning-Eigenschaften.

  12. Wählen Sie eine Aktion Ihrer Wahl aus, z. B. das Senden von E-Mails oder Teams-Nachrichten, das Ausführen von Geschäftsprozessen wie Pipeline, Notizbuch oder Funktionen oder das Ausführen einer benutzerdefinierten Aktion ohne Code mit Power Automate. Wählen Sie Speichern und starten.

    Screenshot der Aktionsauswahlseite mit Optionen zum Senden von Benachrichtigungen oder Ausführen von Geschäftsprozessen.

Nächster Schritt

Weitere Informationen zu Aktivierregeln finden Sie unter Erstellen und Verwalten von Aktivierregeln.