Latencia v Activator

Fabric Activator spúšťa pravidlá pre údaje v reálnom čase. Výsledky sú takmer okamžité, ale existujú faktory, ktoré môžu zaviesť latenciu. Vo väčšine prípadov je toto oneskorenie nepostrehnuteľné, ale v iných prípadoch môže časové oneskorenie dosiahnuť až 10 minút. Prijímanie presných a včasných informácií je dôležitým faktorom pri vytváraní a prijímaní pravidiel. Tento článok popisuje procesy a nastavenia, ktoré určujú rovnováhu medzi zahrnutím udalostí a štruktúrou pravidla, a tým, ako rýchlo sa odošle aktivátor. Má napríklad Activator umožniť prijímanie ďalších údajov a ich zahrnutie alebo by Activator mal zabezpečiť, aby príjemcovia dostávali upozornenia v nastavenom čase? A ako štruktúrovanie pravidla ovplyvňuje rýchlosť, ako sa aktivácia odosiela príjemcom?

Existujú tri dôležité faktory, ktoré ovplyvňujú latenciu aktivácie pravidla:

• Nastavenie používateľa na toleranciu neskorého príchodu.
• Oneskorenie, až o minútu, ktoré môže byť zavedená koncovým spracovaním Activator.
• Agregácie v pravidle.

Tolerancia neskorého príchodu

Tolerancia neskorého príchodu sa nastaví na obrazovke definícia pravidla aktivácie a použije sa na čas príchodu udalosti. Ak sa chcete naučiť, ako nastaviť toleranciu neskorého príchodu, pozrite si tému Nastavenie tolerancie neskorého príchodu.

Latencia serverového spracovania

Pravidlá možno bude potrebné spracovať ešte pred aktiváciou pravidla. Ak ide napríklad o porovnanie s predchádzajúcou množinou udalostí, na načítanie predchádzajúcich údajov, vykonanie porovnania a výpočet výsledku trvá serverové spracovanie. Ďalším príkladom je vtedy, ak je pravidlo spustené voči 10 miliónom riadkov údajov, oneskorenie je zavedené koncovým spracovaním týchto údajov.

Latencia agregácie

Ak sa agregácia použije v definícii pravidla, pravidlo sa aktivuje len po dokončení zadaných časových okien. Povedzme napríklad, že pravidlo je vytvorené tak, aby priemerný počet údajov prekročil štyri hodiny. Ak sa udalosť, ktorá spĺňa podmienky pravidla, uloží o 12:00, pravidlo sa spustí o 16:00. Latencia je výsledkom nastavení agregácie. Dokonca aj vtedy, ak pravidlo obsahuje jednoduchú agregáciu, ako je napríklad priemer, Activator nemôže odoslať aktiváciu, kým Activator nes spustí agregáciu v rámci prichádzajúcich údajov udalosti.

Koncepty času na pozadí

Ak chcete lepšie zarámovať diskusiu, zadefinujme niektoré koncepty na pozadí.

• Čas udalosti: čas, kedy sa pôvodná udalosť stala. Je súčasťou údajovej časti udalosti. Napríklad, keď sa pohyblivé auto na diaľnici približuje k mýtnemu stánku a všimol si ho senzor.
• Čas spracovania: čas, kedy udalosť dosiahne systém spracovania a kedy sa pozoruje. Ak napríklad senzor mýtneho stánku uvidí auto a počítačový systém chvíľu trvá, kým spracuje údaje.
• Čas príchodu (vodotlač alebo čas príjmu): Značka, ktorá označuje, kedy údaje udalosti dosiahnu hodnotu Activator. Prichádzajúce údaje o udalosti sa podľa povahy streamov nikdy neprerušia, takže časy príchodu označujú pokrok, ktorý aktivovateľ dosiahol do určitého bodu v streame. Práve v tomto bode môže nástroj Activator vytvoriť úplné, správne a opakovateľné výsledky, ktoré nie je potrebné zatiahnuť. A práve v tomto bode môže Activator začať s spracovaním údajov. Spracovanie sa dá vykonať predvídateľným a opakovateľným spôsobom. Ak je napríklad potrebné prepočítanie pre určitú podmienku spracovania chýb, časy príchodu sú bezpečnými východiskovými a koncovými bodmi.

Neskoré prijatie nastane, keď pravidlo obsahuje parameter času a čas udalosti je v rámci parametra tohto času, ale čas príchodu nepatrí do tohto parametra. Ak použijeme opäť príklad mýtneho stánku, auto rozpozná senzor mýtneho stánku a čas udalosti sa nachádza v časovom parametri. Activator vidí, že pravidlo má agregáciu a vykonáva túto agregáciu cez údaje. Čas potrebný na vykonanie tejto agregácie umiestni čas príletu mimo parametra času. Táto udalosť je teraz považovaná za neskorú. Ak chcete, aby sa zahrnuli neskoré príchody, nastavte hodnotu tolerancie neskorého príchodu.

Ďalšie zdroje informácií o tejto téme nájdete v blogových príspevkoch Tylera Akidaua Streaming 101 a Streaming 102.

Nastavenie tolerancie neskorého príchodu

Tolerancia neskorého príchodu je nastavením používateľa. Tolerancia neskorého príchodu odkazuje na to, ako dlho Activator čaká na prijatie udalosti a na potvrdenie a spracovanie. Predvolená hodnota je dve minúty. Tolerancia neskorého príchodu prispieva k latencii. Pravidlá, ktoré sa vytvárajú s toleranciou neskorého príchodu, majú latenciu, ktorá je aspoň čas, na ktorý je tolerancia neskorého príchodu nastavená. Pri vytváraní pravidla sa rozhodnite, či sa má použiť predvolená tolerancia alebo či ho zmeniť. Tolerancia zaisťuje, že neskoré udalosti a udalosti, ktoré prídu bez poradia, budú mať príležitosť byť zahrnuté do hodnotenia pravidiel. Ak udalosť spadá mimo tolerancie neskorého príchodu, Activator to neberie do úvahy. Všetky udalosti s časom príchodu po tejto tolerancii sa nevezmú do zohľadnenia.

Celkovo je potrebné zvážiť, či je dôležitejšie:

• Počkať na neskoré údajové body alebo
• spustiť pravidlo o potenciálne neúplných údajoch, aby sa pravidlo aktivovalo skôr. 

V tomto príklade sa údajové body merajú v 15-minútových prírastkoch. Prvé tri bodky, ktoré sú modré, sa vytvárajú v časovom okne. Štvrtá bodka, ktorá je oranžová, nie. Čas udalosti je v 15-minútovom intervale, ale udalosť sa neprenáša podľa funkcie Activator v rámci 15-minútového intervalu. Activator vyhodnotí pravidlo nad údajmi iba s časom príchodu v rámci 15-minútového okna. Pokiaľ používateľ nenaznačí, že chce umožniť toleranciu neskorého príchodu, a počkajte, či sa dostavia iné údajové body. 

Nástroj Activator nemôže za faktor oneskorenia údajov používateľa. Používateľ môže mať napríklad senzory IoT, ktoré sú offline 1 hodinu. Po obnovení režimu online môže Activator prijať údaje, ale údaje sa od tohto stavu v režime offline oneskorili o 1 hodinu, čo sa deje mimo služby Activator.

Tu je ďalší príklad.

Používateľ vytvorí pravidlo, ktoré vypočíta priemernú teplotu v minútových intervaloch. Tolerancia neskorého príchodu je nastavená na hodnotu Predvolené. Predvolená hodnota je dve minúty. Zahrnuté sú hodnoty teploty 20 a 30 a priemerná teplota je 25. Neskorá prichádzajúca udalosť pre 40-stupňovú teplotu však nie je zahrnutá, kým nenastane ďalšie pravidlo aktivácie. 

Čas udalosti	Čas príchodu	Teplota
09:00	09:02	20
09:01	09:03	30
09:02	09:07	40

Dôležité

V súčasnosti nemôžete prepísať predvolenú toleranciu neskorého príchodu. Toto nastavenie sa nevzťahuje ani na pravidlá služby Power BI.

Pravidlá vytvorené na základe vizuálov služby Power BI

Vstavané časové oneskorenie sa v závislosti od služby líši. Latencia pri udalostiach sa líši od latencie vizuálov Služby Power BI. Existujú dve časti, ktoré tvoria latenciu pravidiel vytvorených na základe vizuálov služby Power BI: frekvencia dotazovania vizuálov Power BI, ktorá je vstavaná v systéme, a oneskorenie, ktoré by mohol zaviesť koncový server Activatoru.

Pravidlá služby Power BI sa vyhodnocujú pri každom prijatí nových údajov do Activatoru. Activator ingestuje nové údaje zo služby Power BI každú hodinu. To znamená, že udalosti, ktoré spĺňajú podmienku pravidla spúšťajú aktiváciu v maximálnej jednej hodine po výskyte udalosti. Ďalšie informácie nájdete v téme Získanie údajov pre nástroj Activator zo služby Power BI.