Fabric-Aktivatorregeln

Wenn Sie Streamingdaten in einen Aktivator übertragen oder Objekten Ereignisse zuweisen, können Sie Regeln erstellen, um auf Ihre Daten zu reagieren.

Regeln definieren die Bedingungen, die Sie für Ihre Objekte erkennen möchten, und die Aktionen, die ausgeführt werden sollen, wenn diese Bedingungen erfüllt sind. Beispielsweise kann eine Regel für ein Gefrierobjekt erkennen, wenn die Temperatur über einem sicheren Schwellenwert steigt und automatisch eine E-Mail-Benachrichtigung an den zugewiesenen Techniker sendet.

Jeder Aktivator enthält eine oder mehrere Regeln, die er kontinuierlich auswertet. Diese Regeln können einfache Vergleiche (value < threshold) oder zustandsbehaftete Ausdrücke wie BECOMES, DECREASES, INCREASES, EXIT RANGE oder fehlende Daten (Heartbeat) sein. Aktivator stellt die Zustandsnachverfolgung für jedes Objekt sicher, wodurch die komplexe Mustererkennung im Laufe der Zeit ermöglicht wird.

Aktionen

Wenn die Bedingungen einer Regel erfüllt sind und eine Aktion initiiert wird, wird die Regel aktiviert. Zu den unterstützten Zielen für Aktionen gehören:

• Fabric-Pipelines (für Datenübertragung und Datenanreicherung)

• Fabric-Notizbücher (für die Bewertung von Maschinellem Lernen, Diagnose)

• Fabric Spark-Aufträge (für Batch- und Streamingaufträge)

• Fabric-Funktionen (für benutzerdefinierte Geschäftslogik mit Code)

• Power Automate-Flows (zur Integration von Geschäftsprozessen)

• Teams-Benachrichtigungen (mithilfe von vorlagenbasiertem Messaging)

• E-Mail-Benachrichtigungen

Es gibt drei Arten von Regeln: Regeln für Ereignisse, Regeln für Ereignisse, die Sie einem Objekt hinzufügen, und Regeln für die Eigenschaften eines Objekts.

Erstellen von Regeln für Ereignisse

Wenn Sie Regeln für Ereignisse erstellen, erhalten Sie eine Aktivierung für jedes Ereignis, das in einem Ereignisstream enthalten ist. Mithilfe dieser Regeln können Sie den Status eines Vorgangs im Laufe der Zeit nachverfolgen. Zum Beispiel:

• Sie erhalten eine Benachrichtigung jedes Mal, wenn ein neues Ereignis in einen Ereignisstream kommt, der über Lesewerte von einem einzelnen IoT-Sensor verfügt.
• Sie erhalten eine Warnung jedes Mal, wenn ein neues Ereignis eintritt und der Wert für eine Spalte in diesem Ereignis Ihre definierte Bedingung erfüllt.

Erstellen von Regeln für Objektereignisse

Sie erstellen Objekte aus Streamingdaten und identifizieren sie mithilfe eindeutiger Spalten in einem oder mehreren Datenströmen. Wählen Sie bestimmte Spalten und die eindeutige Spalte aus, die in einem Objekt gebündelt werden soll. Erstellen Sie dann anstelle von Regeln zum Eintreffen von Ereignissen Regeln, die Ereignisse überwachen und entweder über das Eintreffen dieses Objekts oder das Eintreffen eines Objekts berichten, das eine definierte Bedingung erfüllt. Ihre Regel wird jedes Mal aktiviert, wenn ein neues Ereignis im Eventstream-Objekt eintritt. Sie können auch ermitteln, bei welcher Instanz es eingegangen ist.

Erstellen von Regeln für Eigenschaften

Erstellen Sie Regeln für Eigenschaften, um eine Eigenschaft für Objekte im Laufe der Zeit zu überwachen. Wenn Sie den Status einer Eigenschaft für ein Objekt überwachen möchten, erstellen Sie eine Regel für eine Eigenschaft. Beispielsweise können Sie die Temperatur auf einem Paket überwachen und festlegen, ob sie im Laufe der Zeit innerhalb eines festgelegten Bereichs bleibt.

Zustandslose vs. zustandsbehaftete Regeln

Regeln im Aktivator können zustandslos oder zustandsorientiert sein.

• Zustandslose Regeln werten jedes Ereignis isoliert aus (z. B value < 50. ).
• Zustandsbehaftete Regeln speichern Zustandsinformationen für Ereignisse pro Objekt (z. B. value DECREASES, BECOMES, EXIT RANGE).

Die zustandsbehaftete Bewertung basiert auf:

• Deltaerkennung: Verfolgt Änderungen zwischen vorherigen und aktuellen Ereigniswerten.
• Zeitliche Sequenzierung: Wertet zeitbasierte Bedingungen wie das Fehlen von Ereignissen (Takterkennung) aus.
• Zustandsübergänge: Regeln werden nur beim Übergang in einen neuen Zustand ausgelöst und verhindern, dass sie unter unveränderten Bedingungen erneut ausgelöst werden.

Jede Regelbedingung wird in einem Ausführungsgraphen kompiliert, den das System kontinuierlich, im Arbeitsspeicher und nahezu sofort auswertet. Das System ist für eine Entscheidungsfindungslatenz im Subsekundenbereich nach Eintreffen eines Ereignisses optimiert.

Wichtige Entwurfsüberlegungen

• Zustandsbehaftete Logik im Vergleich zur zustandslosen Filterung – Zustandslose Filter (z. B value < 5. ) können zu laut sein. Bevorzugen Sie Übergangslogik wie DECREASES oder BECOMES, um falsch positive Ergebnisse und Spam zu reduzieren.
• Kardinalität des Objektschlüssels – Jeder eindeutige Objektschlüssel (z. B. Geräte-ID) verwendet Arbeitsspeicher und Compute-Tracking. Profilieren Sie sorgfältig Hochkardinalitätsimplementierungen (mehr als 10.000 eindeutige Objekte), um die Leistung aufrechtzuerhalten.
• Kombinieren von Regeln – Aktivator unterstützt sowohl AND als auch OR-Logik. Verwenden Sie sie, um komplexe Erkennungsstrukturen zu erstellen (z. B. verringert sich die Temperatur und der Status wird critical).
• Warnungsermüdungsmanagement – Entwurfsregeln, die nur auf Edgeübergängen ausgelöst werden sollen. Das Aktivierungsmodul unterdrückt automatisch wiederholte Warnungen, es sei denn, ein neuer Zustand tritt ein, aber ein gutes Design vermindert das Rauschen weiter.

Nächster Schritt