Janela de sessão (Azure Stream Analytics)

Eventos de grupo do Windows de sessão que chegam a horas semelhantes, filtrando períodos de tempo em que não existem dados. A função janela de sessão tem três parâmetros principais: tempo limite, duração máxima e chave de criação de partições (opcional).

O diagrama seguinte ilustra um fluxo com uma série de eventos e como são mapeados em janelas de sessão de 5 minutos de tempo limite e duração máxima de 10 minutos.

Uma janela de sessão começa quando ocorre o primeiro evento. Se ocorrer outro evento dentro do tempo limite especificado do último evento ingerido, a janela estende-se para incluir o novo evento. Caso contrário, se não ocorrerem eventos dentro do tempo limite, a janela será fechada no tempo limite.

Se os eventos continuarem a ocorrer dentro do tempo limite especificado, a janela de sessão continuará a prolongar-se até atingir a duração máxima. Tenha em atenção que os intervalos máximos de verificação de duração estão definidos para serem do mesmo tamanho que a duração máxima especificada. Por exemplo, se a duração máxima for 10, verifica se a janela excederá a duração máxima em t = 0, 10, 20, 30, etc. Isto significa que a duração real de uma janela de sessão pode ser até duas vezes maxDuration.

Assim, matematicamente, a nossa janela de sessão termina se a seguinte condição for satisfeita:

Quando é fornecida uma chave de partição, os eventos são agrupados pela chave e a janela de sessão é aplicada a cada grupo de forma independente. Isto é útil para casos em que precisa de janelas de sessão diferentes para diferentes utilizadores ou dispositivos.

Syntax

{SESSIONWINDOW | SESSION} (timeunit, timeoutSize, maxDurationSize) [OVER (PARTITION BY partitionKey)]

{SESSIONWINDOW | SESSION} (Timeout(timeunit , timeoutSize), MaxDuration(timeunit, maxDurationSize)) [OVER (PARTITION BY partitionKey)]

Argumentos

timeunit É a unidade de tempo para o windowsize. A tabela seguinte lista todos os argumentos timeunit válidos.

tempo limite excedido

Um grande número inteiro que descreve o tamanho do intervalo da janela de sessão. Os dados que ocorrem dentro do tamanho do intervalo são agrupados na mesma janela.

maxdurationsize

Se o tamanho total da janela exceder o maxDurationSize especificado num ponto de verificação, a janela será fechada e será aberta uma nova janela no mesmo ponto. Atualmente, o tamanho do intervalo de verificação é igual a maxDurationSize.

partitionkey

Um parâmetro opcional que especifica a chave sobre a qual a janela de sessão funciona. Se for especificado, a janela só agrupa eventos da mesma chave.

Exemplos

Suponha que tem os seguintes dados json:

[
  // time: the timestamp when the user clicks on the link
  // user_id: the id of the user
  // url: the url the user clicked on
  {
    "time": "2017-01-26T00:00:00.0000000z",
    "user_id": 0,
    "url": "www.example.com/a.html"
  },
  {
    "time": "2017-01-26T00:00:20.0000000z",
    "user_id": 0,
    "url": "www.example.com/b.html"
  },
  {
    "time": "2017-01-26T00:00:55.0000000z",
    "user_id": 1,
    "url": "www.example.com/c.html"
  },
  // ...
]

Para medir a duração de cada sessão de utilizador, pode utilizar a seguinte consulta:

CREATE TABLE localinput(time DATETIME, user_id BIGINT, url NVARCHAR(MAX))
SELECT
    user_id,
    MIN(time) AS window_start,
    System.Timestamp() AS window_end,
    DATEDIFF(s, MIN(time), System.Timestamp()) AS duration_in_seconds
FROM localinput TIMESTAMP BY time
GROUP BY user_id, SessionWindow(minute, 2, 60) OVER (PARTITION BY user_id)

A consulta anterior cria uma janela de sessão com um tempo limite de 2 minutos, uma duração máxima de 60 minutos e uma chave de criação de partições de user_id. Isto significa que serão criadas janelas de sessão independentes para cada user_id. Para cada janela, esta consulta irá gerar um resultado que contém o user_id, a hora de início da janela (window_start), o fim da janela (window_end) e a duração total da sessão do utilizador (duration_in_seconds).