Processar eventos usando um operador SQL (visualização)

Um operador SQL (visualização), também chamado de editor de código SQL, é um novo recurso de transformação de dados em fluxos de eventos do Microsoft Fabric. Os operadores SQL fornecem uma experiência de edição de código onde você pode facilmente definir sua própria lógica de transformação de dados personalizada usando expressões SQL simples. Este artigo descreve como usar um operador SQL para transformações de dados em um fluxo de eventos.

Prerequisites

• Acesso a um espaço de trabalho no modo de licença de capacidade do Fabric ou no modo de licença de avaliação, com permissões de Colaborador ou superiores.

Adicionar um operador SQL a um fluxo de eventos

Para executar operações de processamento de fluxo em seus fluxos de dados usando um operador SQL, adicione um operador SQL ao seu fluxo de eventos usando as seguintes instruções:

1. Crie um novo fluxo de eventos. Em seguida, adicione um operador SQL a ele usando uma das seguintes opções:

   • No friso, selecione Transformar eventos e, em seguida, selecione SQL.

     

   • Na tela, selecione Transformar eventos ou adicionar destino e, em seguida, selecione Código SQL.

     

2. Um novo nó SQL é adicionado ao seu fluxo de eventos. Selecione o ícone de lápis para continuar a configurar o operador SQL.

   

3. No painel Código SQL, especifique um nome único para o nó do operador SQL no fluxo de eventos.

4. Edite a consulta na área de consulta ou selecione Editar consulta para inserir a exibição do editor de código em tela cheia.

   

5. O modo de editor de código em tela cheia apresenta um painel explorador de entrada/saída no lado esquerdo. A seção do editor de código é ajustável, para que você possa redimensioná-la de acordo com suas preferências. A seção de visualização na parte inferior permite que você visualize os dados de entrada e o resultado do teste da consulta.

   

6. Selecione o texto na seção Saídas e insira um nome para o nó de destino. O operador SQL suporta todos os destinos do Real-Time Intelligence, incluindo uma casa de eventos, uma casa de lago, um ativador ou um fluxo.

   

7. Especifique um alias ou nome para o destino de saída onde os dados processados por meio do operador SQL são gravados.

   

8. Adicione consulta SQL para a transformação de dados necessária.

   Um fluxo de eventos é criado sobre o Azure Stream Analytics e dá suporte à mesma semântica de consulta da linguagem de consulta do Stream Analytics. Para saber mais sobre a sintaxe e o uso, consulte Azure Stream Analytics e Eventstream Query Language Reference.

   Aqui está a estrutura básica da consulta:

   SELECT 
   
       column1, column2, ... 
   
   INTO 
   
       [output alias] 
   
   FROM 
   
       [input alias] 
   

   Este exemplo de consulta mostra a deteção de altas temperaturas em uma sala a cada minuto:

   
       SELECT 
       System.Timestamp AS WindowEnd, 
       roomId, 
       AVG(temperature) AS AvgTemp 
   INTO 
       output 
   FROM 
       input 
   GROUP BY 
       roomId, 
       TumblingWindow(minute, 1) 
   HAVING 
       AVG(temperature) > 75 
   

   Este exemplo de consulta mostra uma CASE instrução para categorizar a temperatura:

   SELECT
       deviceId, 
       temperature, 
       CASE  
           WHEN temperature > 85 THEN 'High' 
           WHEN temperature BETWEEN 60 AND 85 THEN 'Normal' 
           ELSE 'Low' 
       END AS TempCategory 
   INTO 
       CategorizedTempOutput 
   FROM 
       SensorInput 
   

9. Na faixa de opções, use o comando Test query para validar a lógica de transformação. Os resultados da consulta de teste aparecem na guia Resultado do teste .

   

10. Quando terminar o teste, selecione Salvar na faixa de opções para voltar à tela do fluxo de eventos.

    

11. No painel Código SQL , se o botão Salvar estiver habilitado, selecione-o para salvar as configurações.

    

12. Configure o destino.

    

Limitations

• O operador SQL é projetado para centralizar toda a sua lógica de transformação. Como resultado, você não pode usá-lo junto com outros operadores internos dentro do mesmo caminho de processamento. O encadeamento de vários operadores SQL em um único caminho também não é suportado. Além disso, o operador SQL pode enviar dados de saída somente para o nó de destino na topologia.

• Atualmente, a criação de topologias de fluxo de eventos é suportada apenas por meio da interface do usuário. O suporte à API REST para o operador SQL ainda não está disponível.

Conteúdo relacionado

• Adicionar e gerenciar um destino em um fluxo de eventos