Azure Stream Analytics no IoT Edge

Azure Stream Analytics no IoT Edge é uma versão leve de Azure Stream Analytics que é executada diretamente em dispositivos IoT Edge para análise quase em tempo real em dados gerados pelo dispositivo. Azure Stream Analytics em IoT Edge fornece baixa latência, resiliência, uso eficiente de largura de banda e conformidade regulatória. Você pode implantar a lógica de análise e controle perto de operações industriais usando Azure Stream Analytics baseadas em nuvem para processamento de dados em larga escala.

O Azure Stream Analytics no IoT Edge é executado na estrutura do Azure IoT Edge . Depois de criar um trabalho do Stream Analytics no portal Azure, você pode implantá-lo e gerenciá-lo usando Hub IoT.

Cenários comuns para o Stream Analytics no IoT Edge

O diagrama a seguir mostra o fluxo de dados entre dispositivos IoT e a nuvem do Azure.

Comando e controle de baixa latência

Os sistemas de segurança de fabricação devem responder a dados operacionais com latência ultra baixa. Usando o Stream Analytics em IoT Edge, você pode analisar dados do sensor quase em tempo real e emitir comandos ao detectar anomalias para interromper um computador ou disparar alertas.

Conectividade limitada com a nuvem

Sistemas críticos de missão, como equipamentos de mineração remota, embarcações conectadas ou perfuração offshore, precisam analisar e reagir aos dados mesmo quando a conectividade de nuvem é intermitente. Usando o Stream Analytics, sua lógica de streaming é executada independentemente da conectividade de rede e você pode escolher o que enviar para a nuvem para processamento ou armazenamento adicionais.

Largura de banda limitada

O volume de dados produzidos por motores a jato ou carros conectados pode ser tão grande que você deve filtrar ou pré-processá-los antes de enviá-los para a nuvem. Usando o Stream Analytics, você pode filtrar ou agregar os dados que precisa enviar para a nuvem.

Conformidade regulatória e processamento de dados locais

A conformidade regulatória pode exigir que você anonimize ou agrege alguns dados localmente antes de enviá-los para a nuvem. Usando o Stream Analytics em IoT Edge, você pode processar dados confidenciais localmente e enviar apenas resultados em conformidade e transformados para a nuvem.

Trabalhos de borda no Azure Stream Analytics

Os trabalhos de borda do Stream Analytics são cargas de trabalho do Stream Analytics em contêineres que são implantadas em dispositivos Azure IoT Edge. As tarefas de edge têm duas partes:

• Uma parte de nuvem que manipula a definição de trabalho: você define entradas, saída, consulta e outras configurações, como eventos fora de ordem, na nuvem.

• Um módulo em execução em seus dispositivos IoT. O módulo contém o mecanismo do Stream Analytics e recebe a definição de trabalho da nuvem.

O Stream Analytics usa o Hub IoT para implantar tarefas de borda em dispositivos. Para obter mais informações, consulte a implantação do IoT Edge.

Limitações de trabalho de borda

Os trabalhos de borda do Stream Analytics visam a paridade entre implantações de borda e nuvem. Um trabalho de nuvem é um trabalho de Azure Stream Analytics padrão executado em Azure, enquanto um trabalho de borda é executado localmente em um dispositivo IoT Edge. O Stream Analytics dá suporte à maioria dos recursos de linguagem de consulta SQL para borda e nuvem. No entanto, as tarefas de borda não oferecem suporte aos seguintes recursos:

• UDF (funções definidas pelo usuário) em JavaScript. Os UDFs estão disponíveis em C# para trabalhos IoT Edge (versão prévia).
• Agregações definidas pelo usuário (UDA).
• Funções do Azure Machine Learning
• Formato AVRO para entrada/saída. Os Edge jobs oferecem suporte apenas aos formatos CSV e JSON.
• Os seguintes operadores SQL:
  • PARTITION BY
  • GetMetadataPropertyValue
• Política de chegada tardia

Requisitos de tempo de execução e hardware

Para executar o Stream Analytics no IoT Edge, você precisa de dispositivos que executam Azure IoT Edge.

O Stream Analytics e o Azure IoT Edge usam contêineres do Docker para fornecer uma solução portátil que é executada em vários sistemas operacionais host (Windows, Linux).

O Stream Analytics no IoT Edge é executado na forma de imagens Linux em arquiteturas x86-64 e ARM.

Entradas e saídas para tarefas de borda do Stream Analytics

Os trabalhos de borda do Stream Analytics recebem entradas e saídas de outros módulos em execução em dispositivos IoT Edge. Para se conectar de e a módulos específicos, defina a configuração de roteamento no momento da implantação. Para obter mais informações, consulte a documentação de composição do módulo IoT Edge.

Entradas e saídas dão suporte a formatos CSV e JSON.

Para cada fluxo de entrada e saída que você cria em seu trabalho do Stream Analytics, o Stream Analytics cria um ponto de extremidade correspondente em seu módulo implantado. Use estes endpoints nas rotas da sua implantação.

Os tipos de entrada de fluxo com suporte são:

• Hub do Edge
• Hub de evento
• Hub IoT

Os tipos de saída de fluxo com suporte são:

• Hub do Edge
• Banco de Dados SQL
• Hub de evento
• Armazenamento de Blobs/Azure Data Lake Storage Gen2

A entrada de referência dá suporte ao tipo de arquivo de referência, que fornece dados estáticos ou de alteração lenta para pesquisas. Para atingir outros destinos de saída, encadeie, a jusante, um trabalho do Stream Analytics hospedado na nuvem. Por exemplo, um trabalho do Stream Analytics hospedado no IoT Edge envia a saída ao Edge Hub, que pode então encaminhá-la ao Hub IoT. Use uma segunda tarefa do Azure Stream Analytics hospedada na nuvem com entrada do Hub IoT e saída para o Power BI ou outro tipo de saída.

Informações de imagem do módulo do Azure Stream Analytics

A tabela a seguir lista as imagens disponíveis do módulo Stream Analytics no IoT Edge. Estas informações de versão foram atualizadas pela última vez em 2020-09-21. Verifique o Registro de Contêineres da Microsoft para as versões mais recentes disponíveis.

Conteúdo relacionado

• O que é o Azure IoT Edge?
• Tutorial: implantar Azure Stream Analytics como um módulo IoT Edge
• Desenvolver trabalhos do Stream Analytics Edge usando ferramentas do Visual Studio
• Implementar CI/CD para Stream Analytics usando APIs
• Microsoft Q&A para Azure Stream Analytics