Finestra a cascata

✅ Flusso di eventi dell'infrastruttura di Analisi ✅ di flusso di Azure

Le finestre a cascata sono una serie di intervalli di tempo fissi, non sovrapposti e contigui. Il diagramma seguente illustra un flusso con una serie di eventi e come vengono mappati in finestre a cascata di 10 secondi.

flusso

Sintassi

{TUMBLINGWINDOW | TUMBLING} ( timeunit  , windowsize, [offsetsize] )  
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit  , windowsize ), [Offset(timeunit  , offsetsize)] )  
  

Annotazioni

La finestra a cascata può essere usata nei due modi precedenti. Per consentire la coerenza con la finestra di salto, la funzione Duration può essere usata anche con tutti i tipi di finestre per specificare le dimensioni della finestra. La durata della finestra deve essere una costante float positiva.

Argomenti

timeunit

Unità di tempo per le finestre. Nella tabella seguente sono elencati tutti gli argomenti timeunit validi.

Timeunit	Abbreviazioni
giorno	dd, d
ora	Hh
minuto	mi, n
secondo	ss, s
millisecondo	ms
microsecondo	Mcs

windowsize

Intero grande che descrive le dimensioni della finestra. Windowsize è statico e non può essere modificato in modo dinamico in fase di esecuzione.

La dimensione massima della finestra è di 7 giorni.

offsetsize

Per impostazione predefinita, le finestre a cascata sono incluse alla fine della finestra ed esclusive all'inizio, ad esempio le 12:00 - 13:00 finestra includeranno eventi che si sono verificati esattamente alle 13:00, ma non includeranno eventi che si sono verificati alle 12:00 (questi eventi faranno parte della finestra delle 11:00 - 12:00 PM).

Il parametro Offset può essere usato per modificare questo comportamento e includere gli eventi all'inizio della finestra ed escludere quelli che si sono verificati alla fine.

Esempi

SELECT System.Timestamp() AS WindowEnd, TollId, COUNT(*)  
FROM Input TIMESTAMP BY EntryTime  
GROUP BY TollId, TumblingWindow(Duration(hour, 1), Offset(millisecond, -1))

SELECT 'reset' AS command
INTO
    alert
FROM
    temperature TIMESTAMP BY timeCreated
GROUP BY TumblingWindow(second,15)
HAVING Avg(machine.temperature) > 25

Considerazioni sul tempo

Ogni operazione di finestra restituisce l'evento alla fine della finestra. Le finestre di Analisi di flusso di Azure vengono aperte all'ora di inizio della finestra e chiuse all'ora di fine della finestra. Ad esempio, se si ha una finestra di 5 minuti dalle 12:00 alle 12:05, tutti gli eventi con timestamp maggiore delle 12:00 e fino al timestamp 12:05 inclusi in questa finestra. L'output della finestra sarà un singolo evento basato sulla funzione di aggregazione usata con un timestamp uguale all'ora di fine dell'intervallo. Il timestamp dell'evento di output della finestra può essere proiettato nell'istruzione SELECT usando la proprietà System.Timestamp() usando un alias.

Vedere anche

Finestra di salto
Finestra scorrevole
Gestione delle finestre