Funções de janela

✅ Fluxo de eventos do Azure Stream Analytics ✅ Fabric

Em aplicativos que processam eventos em tempo real, é comum executar alguma computação baseada em conjunto (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 com suporte e explica como você pode usar janelas com vários operadores.

Noções básicas sobre o Windows

Uma janela contém dados de evento 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, talvez você queira somar os valores dos campos de carga em uma determinada janela, conforme mostrado na ilustração a seguir.

Cada operação de janela gera 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 00h às 00h05, todos os eventos com carimbo de data/hora maior que 12h e até o carimbo de data/hora 12:05, inclusive, serão incluídos nesta janela. A saída da janela será um único evento com base na função de agregação 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 se alinha automaticamente à hora zero. Por exemplo, uma janela em cascata de 5 minutos se alinhará 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 de evento original (a hora de chegada ou a coluna usada com TIMESTAMP BY). O carimbo de data/hora atual atualizado de um evento sempre pode ser acessado com system.timestamp().

Há cinco tipos de janelas:

1. Janela em cascata

2. Janela de salto

3. Janela Deslizante

4. Janela sessão

5. Janela instantâneo

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

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

Consulte Também

Funções internas
Funções agregadas
Funções analíticas
Funções de matriz (Stream Analytics)
Funções de conversão de
Funções de data e hora
Funções de registro