Cos’è Data Activator
Data Activator è il servizio di Real-Time Intelligence in Microsoft Fabric che monitora flussi di dati in modo continuo e lancia azioni automatiche quando una condizione si verifica, senza scrivere codice imperativo. È lo strato “detect and act”: osserva i dati che scorrono, valuta regole e reagisce.
L’artefatto Fabric si chiama Reflex. Al suo interno si modella il dominio di business tramite tre elementi:
- Object: l’entità di business che vuoi monitorare (una pompa, un ordine, un negozio, un server). Ogni istanza è identificata da una chiave (es.
DeviceId). - Property: un valore calcolato e mantovanuto nel tempo per l’object (es.
temperatura,fatturato_orario,latenza). Le property sono riutilizzabili tra più trigger. - Trigger: la condizione che, quando diventa vera, esegue una o più azioni.
Sorgenti dati
Data Activator si aggancia a tre sorgenti principali:
- Eventstream: telemetria in streaming (IoT, eventi applicativi, click, log). È il caso tipico per volumi elevati e latenza bassa.
- Power BI: si aggiunge un trigger direttamente da una visual, monitorando una misura del report (es. avvisa quando le vendite di una categoria scendono sotto soglia).
- KQL / Real-Time Dashboard: si parte da una query KQL su un Eventhouse/KQL Database per condizioni analitiche più ricche.
La differenza architetturale chiave: da Eventstream i dati arrivano evento per evento (routing diretto), mentre da Power BI o KQL si valuta a intervalli di refresh della misura/query. Se lo scenario richiede reazione in secondi su telemetria grezza, la strada corretta è Eventstream, non Power BI.
Azioni disponibili
Quando un trigger scatta, Data Activator può eseguire:
- Email: notifica con contesto (valori dell’object che ha attivato la regola).
- Microsoft Teams: messaggio a persona o canale.
- Power Automate: avvia un flow, ponte verso qualsiasi sistema esterno (ticket, ERP, webhook, SMS).
- Custom action / Fabric item: es. eseguire una pipeline o un job, utile per orchestrare rielaborazioni a valle.
Per integrazioni non native o logiche complesse, Power Automate è la scelta corretta: Data Activator gestisce il detect, il flow gestisce l’act verso il mondo esterno.
Casi d’uso tipici
- Soglie IoT: temperatura di una cella frigorifera oltre limite, vibrazione anomala di un macchinario (manutenzione predittiva).
- Anomalie di business: fatturato orario che crolla, tasso di errore di checkout che sale, stock che scende sotto il punto di riordino.
- SLA e monitoring: latenza di un servizio sopra il target per un tempo definito, job che non produce eventi entro la finestra attesa (assenza di segnale).
Valutazione stateful nel tempo
Questo è il concetto architetturale più importante e più frainteso. Data Activator mantiene lo stato per ogni object nel tempo: non valuta un singolo record isolato, ma l’evoluzione della property.
Questo permette condizioni come:
- “diventa vero” (edge trigger): scatta solo alla transizione, non a ogni evento che resta sopra soglia — evita spam di notifiche.
- “resta vero per almeno N minuti”: introduce una finestra temporale che distingue un picco istantaneo (rumore) da una condizione persistente (problema reale).
- “cambia di X%”, “esce dall’intervallo”, “aumenta/diminuisce”.
Progettare bene la finestra e il tipo di trigger è ciò che separa un alerting affidabile da un sistema che genera falsi allarmi e viene ignorato.
Trappole tipiche d’esame
- Scenario: un sensore supera occasionalmente la soglia per un istante, ma vuoi allertare solo se il problema persiste → risposta: aggiungi una condizione di durata (“resta sopra soglia per almeno X minuti”), non un trigger su singolo valore. La valutazione stateful è il punto.
- Scenario: ricevi decine di email perché il valore resta sopra soglia → risposta: usa un trigger “becomes true” (sulla transizione), non uno che scatta a ogni evento.
- Scenario: monitorare telemetria IoT ad alta frequenza con reazione in secondi → risposta: sorgente Eventstream, non un trigger su misura Power BI (refresh troppo lento).
- Scenario: quando scatta la condizione serve creare un ticket in un sistema esterno → risposta: azione Power Automate, non semplice email.
- Scenario: alert su una misura di vendita già presente in un report → risposta: aggiungi il trigger direttamente dalla visual di Power BI, senza ricostruire la logica in KQL.