Nota
O acesso a esta página requer autorização. Pode tentar iniciar sessão ou alterar os diretórios.
O acesso a esta página requer autorização. Pode tentar alterar os diretórios.
✅ Azure Stream Analytics ✅ Fabric Eventstream
As janelas de tombamento são uma série de intervalos de tempo de tamanho fixo, não sobrepostos e contíguos. O diagrama a seguir ilustra um fluxo com uma série de eventos e como eles são mapeados em janelas de tombamento de 10 segundos.
Sintaxe
{TUMBLINGWINDOW | TUMBLING} ( timeunit , windowsize, [offsetsize] )
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit , windowsize ), [Offset(timeunit , offsetsize)] )
Observação
A janela de tombamento pode ser usada das duas maneiras acima. Para permitir a consistência com a janela de salto, a função Duração também pode ser usada com todos os tipos de janelas para especificar o tamanho da janela. A duração da janela deve ser uma constante de flutuação positiva.
Argumentos
unidade de tempo
É a unidade de tempo para o tamanho da janela. A tabela a seguir lista todos os argumentos de unidade de tempo válidos.
| Unidade de tempo | Abreviações |
|---|---|
| Dia | DD, D |
| hora | HH |
| minuto | mi, n |
| segundo | SS, S |
| milissegundos | em |
| microssegundos | MCS |
tamanho da janela
Um grande número inteiro que descreve o tamanho da janela. O tamanho da janela é estático e não pode ser alterado dinamicamente em tempo de execução.
O tamanho máximo da janela é de 7 dias.
tamanho do deslocamento
Por padrão, as janelas de tombo são inclusivas no final da janela e exclusivas no início – por exemplo, a janela 12:00 – 13:00 incluirá eventos que aconteceram exatamente às 13:00, mas não incluirá eventos que aconteceram às 12:00 (esses eventos farão parte da janela 11:00 – 12:00).
O parâmetro Offset pode ser usado para alterar esse comportamento e incluir os eventos no início da janela e excluir os que aconteceram no final.
Exemplos
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
Considerações de tempo
Cada operação de janela produz um evento no final da janela. As janelas do Azure Stream Analytics são abertas na hora de início da janela e fechadas na hora de término da janela. Por exemplo, se você tiver uma janela de 5 minutos das 12h00 às 12h05, todos os eventos com carimbo de data/hora maior que 12h00 e até carimbo de data/hora 12h05, inclusive, serão incluídos nessa janela. A saída da janela será um único evento baseado na função agregada usada com um carimbo de data/hora igual à hora de término da janela. O carimbo de data/hora do evento de saída da janela pode ser projetado na instrução SELECT usando a propriedade System.Timestamp() usando um alias.