Funções de janelas

✅ Azure Stream Analytics ✅ Fabric Eventstream

Em aplicativos que processam eventos em tempo real, é comum executar alguns cálculos baseados em conjuntos (agregação) ou outras operações em subconjuntos de eventos que se enquadram em algum período de tempo. Como o conceito de tempo é uma necessidade fundamental para sistemas complexos de processamento de eventos, é importante ter uma maneira simples de trabalhar com o componente de tempo da lógica de consulta no sistema. No Azure Stream Analytics, esses subconjuntos de eventos são definidos por meio de janelas para representar agrupamentos por tempo. Este artigo descreve as janelas e como elas são definidas, identifica os tipos de janelas suportadas e explica como você pode usar as janelas com vários operadores.

Noções básicas sobre o Windows

Uma janela contém dados de eventos ao longo de uma linha do tempo e permite que você execute várias operações em relação aos eventos dentro dessa janela. Por exemplo, você pode querer somar os valores dos campos de carga útil em uma determinada janela, conforme mostrado na ilustração a seguir.

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. Cada janela alinha-se automaticamente à hora zero. Por exemplo, uma janela de queda de 5 minutos irá alinhar-se a (12:00-12:05] , (12:05-12:10], ..., e assim por diante.

Após uma operação de janela, o carimbo de data/hora de um evento será diferente do atributo de hora do evento original (a hora de chegada ou a coluna usada com TIMESTAMP BY). O carimbo de data/hora atual e atualizado de um evento sempre pode ser acessado com system.timestamp().

Existem cinco tipos de janelas:

1. Janela de tombo

2. Janela de salto

3. Janela Deslizante

4. Janela da sessão

5. Janela de instantâneo

O tamanho máximo da janela em todos os casos é de 7 dias.

Você pode agregar várias janelas de tempo na mesma instrução GROUP BY usando a função Windows .

Ver também

Funções Embutidas
Funções agregadas
Funções Analíticas
Funções de array (Stream Analytics)
Funções de conversão
Funções de data e hora
Funções de Registo