System.Timestamp() (Stream Analytics)

Artigo
08/02/2024

Cada evento em cada estágio da consulta no Azure Stream Analytics tem um carimbo de data/hora associado a ele. System.Timestamp() é uma propriedade do sistema que pode ser usada para recuperar o carimbo de data/hora do evento.

Abaixo, descrevemos como o Azure Stream Analytics atribui carimbos de data/hora a eventos.

Carimbo de data/hora de eventos de entrada

O carimbo de data/hora do evento de entrada pode ser definido pelo valor da coluna (ou uma expressão) especificado na cláusula TIMESTAMP BY :

SELECT System.Timestamp() t   
FROM input   
TIMESTAMP BY MyTimeField

Se uma cláusula TIMESTAMP BY não for especificada para uma determinada entrada, a hora de chegada do evento será usada como um carimbo de data/hora. Por exemplo, a hora enfileirada do evento será usada no caso de entrada do Hub de Eventos.

Carimbo de data/hora do evento resultante

Quando os cálculos são executados, o carimbo de data/hora do evento resultante é o momento lógico mais antigo em que esse resultado pode ser determinado.

Vamos examinar como as operações de consulta básicas no Azure Stream Analytics (filtros, projeções, agregações e junções) geram os carimbos de data/hora para o resultado.

Projeção

SELECT  
      Prop1,  
      Prop2,  
      Prop3 - Prop4 / 12,
      System.Timestamp() t  
FROM input

As projeções não alteram o carimbo de data/hora do evento, o carimbo de data/hora do resultado é o mesmo que o carimbo de data/hora da entrada.

Filter

SELECT *  
FROM input  
WHERE prop1 > prop2

Os filtros não alteram o carimbo de data/hora do evento. O carimbo de data/hora do resultado é o mesmo que o carimbo de data/hora da entrada.

GROUP BY ao longo da janela de tempo

SELECT  
      userId,  
      AVG(prop1),  
      SUM(prop2),  
      System.Timestamp() t  
FROM input  
GROUP BY TumblingWindow(minute, 1), userId

O carimbo de data/hora do resultado da agregação é o fim da janela de tempo à qual esse resultado corresponde. Consulte os artigos Janelas (Azure Stream Analytics) que descrevem diferentes tipos de janela no Azure Stream Analytics.

INNER JOIN

SELECT  
      System.Timestamp()  
FROM input1  
JOIN input2  
ON DATEDIFF(minute, input1, input2) BETWEEN 0 AND 10

Uma junção interna produz resultados que correspondem a pares de eventos correspondentes de input1 e input2.

O evento que representa a correspondência do evento e1 de input1 e e2 de input2 é carimbo de data/hora pelo mais recente dos carimbos de data/hora de e1 e e2.

LEFT OUTER JOIN

SELECT  
      System.Timestamp()  
FROM input1  
LEFT JOIN input2  
ON DATEDIFF(minute, input1, input2) BETWEEN -2 AND 10

Uma junção esquerda-externa produz resultados de dois tipos. Alguns correspondem a um par de eventos correspondentes de input1 e input2; outros correspondem a apenas um evento de input1 e indicam que nenhum evento correspondente de input2 foi encontrado.

Os eventos que representam uma correspondência (tem input1 e input2) têm o carimbo de data/hora mais recente dos carimbos de data/hora das entradas correspondentes (como no caso da INNER JOIN acima).

Os eventos que representam não correspondências (input2 é NULL) são carimbo de data/hora pela hora lógica mais recente em que um evento input2 correspondente poderia ter ocorrido. Por exemplo, no exemplo acima, é o carimbo de data/hora de input1 + 10 minutos.

Compartilhar via