Regole dell'attivatore di fabric

Quando si inseriscono dati di streaming in un attivatore o si assegnano eventi a oggetti, è possibile creare regole per agire sui dati.

Le regole definiscono le condizioni che si desidera rilevare sugli oggetti e le azioni da eseguire quando vengono soddisfatte tali condizioni. Ad esempio, una regola su un oggetto freezer potrebbe rilevare quando la temperatura aumenta al di sopra di una soglia sicura e invia automaticamente un avviso di posta elettronica al tecnico assegnato.

Ogni attivatore include una o più regole, che valuta continuamente. Queste regole possono essere semplici confronti (value < threshold) o espressioni con stato come BECOMES, DECREASES, INCREASES, EXIT RANGE o assenza di dati (heartbeat). L'attivatore garantisce il tracciamento dello stato per ogni oggetto, che consente il rilevamento di pattern complessi nel tempo.

Azioni

Quando vengono soddisfatte le condizioni di una regola e viene avviata un'azione, la regola viene attivata. Destinazioni supportate per le azioni includono:

• Pipeline di infrastruttura (per lo spostamento dei dati, arricchimento)

• Notebook Fabric (per il punteggio e la diagnostica del Machine Learning)

• Lavori Spark su Fabric (per lavori batch e di streaming)

• Funzioni di fabric (per la logica aziendale personalizzata nel codice)

• Flussi di Power Automate (per l'integrazione dei processi aziendali)

• Notifiche di Teams (tramite messaggistica basata su modelli)

• Notifiche tramite posta elettronica

Esistono tre tipi di regole: regole per gli eventi, regole sugli eventi aggiunti a un oggetto e regole sulle proprietà di un oggetto.

Creare regole per gli eventi

Quando si creano regole per gli eventi, si ottiene un'attivazione per ogni evento incluso in un flusso di eventi. Usando queste regole, è possibile tenere traccia dello stato di un elemento nel tempo. Per esempio:

• Si riceve un avviso ogni volta che viene generato un nuovo evento in un flusso di eventi con letture da un singolo sensore IoT.
• Viene visualizzato un avviso ogni volta che viene visualizzato un nuovo evento e il valore di una colonna in tale evento soddisfa la condizione definita.

Creare regole per gli eventi Object

È possibile creare oggetti dai dati di streaming e identificarli usando colonne univoce in uno o più flussi. Selezionare colonne specifiche e la colonna univoca da aggregare in un oggetto . Quindi, invece di creare regole all'arrivo degli eventi, creare regole che monitorano gli eventi e segnalano l'arrivo di tale oggetto o l'arrivo di un oggetto che soddisfa una condizione definita. La regola viene attivata ogni volta che viene generato un nuovo evento sull'oggetto eventstream. È anche possibile identificare l'istanza per cui è stata inserita.

Creare regole per le proprietà

Creare regole sulle proprietà per monitorare una proprietà sugli oggetti nel tempo. Se si desidera monitorare lo stato di una proprietà su un oggetto, creare una regola sulla proprietà. Ad esempio, è possibile monitorare la temperatura in un pacchetto e se rimane entro un intervallo di tempo impostato.

Regole senza stato e con stato

Le regole in Activator possono essere senza stato o con stato:

• Le regole senza stato valutano ogni evento in isolamento (ad esempio, value < 50).
• Le regole con stato mantengono la memoria tra eventi per oggetto ( ad esempio , value DECREASESBECOMES, ). EXIT RANGE

La valutazione basata sullo stato si basa su:

• Rilevamento delta: traccia le modifiche tra i valori degli eventi precedenti e quelli correnti.
• Sequenziazione temporale: valuta le condizioni basate sul tempo, ad esempio l'assenza di eventi (rilevamento heartbeat).
• Transizioni di stato: le regole vengono attivate solo all'ingresso in un nuovo stato, evitando attivazioni ripetute in condizioni invariate.

Ogni condizione della regola viene compilata in un grafico di esecuzione che il sistema valuta in modo continuo, in memoria e quasi istantaneamente. Il sistema è ottimizzato per una latenza di decisione inferiore al secondo dopo l'arrivo dell'evento.

Considerazioni chiave sulla progettazione

• Logica con stato e filtro senza stato : i filtri senza stato (ad esempio, value < 5) potrebbero essere troppo rumorosi. Preferisci la logica transitoria come DECREASES e BECOMES per ridurre i falsi positivi e la posta indesiderata.
• Cardinalità della chiave dell'oggetto - ogni chiave univoca dell'oggetto (ad esempio, ID dispositivo) utilizza memoria e risorse di calcolo per il monitoraggio. Profilare attentamente implementazioni con cardinalità elevata (più di 10.000 oggetti univoci) per mantenere le prestazioni.
• Combinazione di regole : Activator supporta la logica AND e OR. Usarli per creare alberi di rilevamento complessi (ad esempio, la temperatura diminuisce e lo stato diventa critical).
• Gestione dell'affaticamento degli avvisi : le regole di progettazione vengono attivate solo sulle transizioni perimetrali. L'attivatore elimina automaticamente gli avvisi ripetuti a meno che non venga immesso un nuovo stato, ma una progettazione efficace riduce ulteriormente il rumore.

Passaggio successivo