DE

✅ Fluxo de eventos do Azure Stream Analytics ✅ Fabric

Especifica o fluxo de entrada ou um nome de etapa associado em uma cláusula WITH. A cláusula FROM é sempre necessária para qualquer comando SELECT.

Sintaxe

FROM <input_source> [<PARTITION BY clause>] [<TIMESTAMP BY clause>]
  
<PARTITION BY clause> ::== PARTITION BY <key_spec>

<TIMESTAMP BY clause> ::== TIMESTAMP BY scalar_expression [OVER <key_spec>]

<input_source> ::=   
    {   
      *   
      | { input_name |  input_alias }.*   
      | {  
          [ { input_name | input_alias }. ]  
               { column_name }  
     | expression [ [ AS ] column_alias ]  
         }  
      | column_alias = expression   
    }

<key_spec> ::== { column_name | expression } [,... n]

Argumentos

*

Especifica que todas as colunas de todos os fluxos de entrada na cláusula FROM devem ser retornadas. As colunas são retornadas pela origem de entrada, conforme especificado na cláusula FROM e na ordem em que elas existem no fluxo de entrada.

input_name | input_alias.*

Limita o escopo do * ao nome de entrada especificado.

column_name

É o nome de uma coluna a ser retornada. Qualifique column_name para impedir uma referência ambígua, como ocorre quando duas fontes de entrada na cláusula FROM têm colunas com nomes duplicados.

expressão

É uma constante, função, qualquer combinação de nomes de coluna, constantes e funções conectadas por um operador ou operadores ou uma subconsulta.

Column_alias

É um nome alternativo para substituir o nome da coluna no conjunto de resultados da consulta. Por exemplo, um alias como Quantidade ou Quantidade para Data ou Qty pode ser especificado para uma coluna chamada quantidade. Os aliases também são usados para especificar nomes para os resultados das expressões. column_alias não pode ser usado em uma cláusula WHERE, GROUP BY ou HAVING.

PARTITON BY <key_spec>

Particiona dados em subconjuntos com base em <key_spec>. Isso permite que o trabalho consuma e escreva partições diferentes em paralelo. Para obter mais informações, confira Aproveitar a paralelização de consultas no Azure Stream Analytics.

TIMESTAMP BY scalar_expression [OVER <key_spec>]

Permite que os eventos sejam carimbos de data/hora por scalar_expression em vez da hora de chegada. A cláusula OVER pode ser usada para criar linhas do tempo independentes para cada chave distinta. Para obter mais informações, consulte a documentação sobre TIMESTAMP BY.

Exemplo

SELECT TollId, EntryTime AS VehicleEntryTime, LicensePlate, State, Make, Model, VehicleType, VehicleWeight, Toll, Tag   
FROM TollTagEntry TIMESTAMP BY EntryTime