Desenvolva trabalhos do Stream Analytics no Edge com as ferramentas do Visual Studio

Neste artigo, você aprenderá a usar as ferramentas do Stream Analytics para o Visual Studio para criar, depurar e gerar trabalhos do Stream Analytics Edge. Depois de criar e testar o trabalho, você vai ao portal do Azure para implantá-lo nos seus dispositivos.

Pré-requisitos para desenvolver tarefas de Edge

Você precisa dos seguintes pré-requisitos para completar as etapas deste artigo:

  1. Instale o Visual Studio 2019, Visual Studio 2015 ou Visual Studio 2013 Atualização 4. As ferramentas de Análise de Fluxo suportam as edições Enterprise (Ultimate/Premium), Professional e Community, mas não a edição Express.

  2. Siga as instruções de instalação para instalar as ferramentas do Stream Analytics para Visual Studio.

Crie um projeto Stream Analytics Edge

Crie o projeto Edge que contenha a definição do seu cargo.

  1. No Visual Studio, selecione Arquivo>Novo>Projeto. Vá para a lista Modelos à esquerda e, em seguida, expanda Azure Stream Analytics>Stream Analytics Edge>Azure Stream Analytics Edge Application. Insira um nome, localização e nome da solução para o seu projeto, e então selecione OK.

    Captura de tela da caixa de diálogo New Project para criar um aplicativo Azure Stream Analytics Edge no Visual Studio.

  2. Depois que o Visual Studio criar o projeto, vá até o Gerenciador de Soluções para visualizar a hierarquia de pastas.

    Captura de tela do Gerenciador de Soluções mostrando a hierarquia de pastas de um projeto Stream Analytics Edge no Visual Studio.

Escolha a assinatura correta

Conecte o Visual Studio à assinatura do Azure onde você quer criar o trabalho.

  1. No menu Visualização do Visual Studio, selecione Explorador de Servidores.

  2. Selecione e segure (ou clique com o botão direito) no Azure, selecione Conectar à Assinatura do Microsoft Azure e então faça login com sua conta Azure.

Definir entradas

Configure a entrada do Hub do Edge da qual o trabalho lê eventos em streaming.

  1. No Gerenciador de Soluções, expanda o nó Entradas. Você vê uma entrada chamada EdgeInput.json. Abra para ver as configurações.

  2. Defina o tipo de fonte para fluxo de dados. Depois, defina a fonte para Edge Hub, o formato de serialização de eventos para Json e a codificação para UTF8. Opcionalmente, renomeie o Alias de Entrada, mas deixe como está neste exemplo. Se você renomear o alias de entrada, use o nome que especificar ao definir a consulta. Selecione Salvar para salvar as configurações. Captura de tela das configurações de configuração do Stream Analytics Edge Hub no Visual Studio.

Definir saídas

Configure a saída do Edge Hub para a qual o trabalho grava os resultados.

  1. No Gerenciador de Soluções, expanda o nó Saídas. Você vê uma saída chamada EdgeOutput.json. Abra para ver as configurações.

  2. Defina o Coletor como Hub do Edge, defina o Formato de Serialização de Evento como Json, defina Codificação como UTF8 e defina o formato como Matriz. Opcionalmente, renomeie o Alias de Saída, mas deixe como está neste exemplo. Se você renomear o alias de saída, use o nome que especificar ao definir a consulta. Selecione Salvar para salvar as configurações. Captura de tela das configurações de configuração do Stream Analytics Edge Hub no Visual Studio.

Revise operações não suportadas

Os trabalhos do Stream Analytics implantados nos ambientes IoT Edge do Stream Analytics têm suporte para a maior parte da Referência da Linguagem de Consulta do Stream Analytics. No entanto, as seguintes operações não são suportadas para trabalhos de Stream Analytics Edge:

  1. PARTICIONAMENTO POR
  2. CARIMBO TEMPORAL POR OVER
  3. UDF do JavaScript
  4. Agregados definidos pelo usuário (UDA)
  5. GetMetadataPropertyValue
  6. Usando mais de 14 agregados em um único passo

Quando você cria um job Stream Analytics Edge no portal, o compilador avisa automaticamente se você não estiver usando um operador suportado.

Definir a consulta de transformação

A partir do Visual Studio, defina a seguinte consulta de transformação no editor de consultas (o script.asaql arquivo).

SELECT * INTO EdgeOutput
FROM EdgeInput

Teste o trabalho localmente

Para testar a consulta localmente, faça upload dos dados de amostra. Para obter dados de exemplo, baixe os dados de registro do repositório do GitHub e salve no seu computador local.

  1. Para enviar dados de exemplo, selecione e segure (ou clique com o botão direito) no arquivoEdgeInput.json , e então selecione Adicionar Entrada Local.

  2. Na janela pop-up, navegue pelos dados de exemplo do seu caminho local e selecione Salvar.

    Captura de tela da configuração local de entrada para upload de dados de exemplo no Visual Studio.

  3. Visual Studio adiciona automaticamente um arquivo chamado local_EdgeInput.json à sua pasta de entradas.

  4. Você pode rodar localmente ou enviar para o Azure. Para testar a consulta, selecione Executar Localmente.

    Captura de tela das opções de execução de tarefas do Stream Analytics mostrando Executar Localmente no Visual Studio.

  5. A janela do prompt de comando mostra o status da tarefa. Quando o trabalho é executado com sucesso, ele cria uma pasta semelhante a 2018-02-23-11-31-42 no caminho da pasta do seu projeto Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42. Vá até o caminho da pasta para ver os resultados na pasta local.

    Você também pode fazer login no portal do Azure e verificar se o trabalho foi criado.

    Captura de tela da pasta de resultados de trabalhos do Stream Analytics mostrando a saída local da execução no Visual Studio.

Submeta o trabalho para o Azure

Depois de testar a consulta, publique o trabalho na sua assinatura do Azure.

  1. Antes de enviar o trabalho para o Azure, conecte-se à sua assinatura do Azure. Abra o Explorador de Servidores, selecione e segure (ou clique com o botão direito) no Azure, selecione Conectar à assinatura do Microsoft Azure e então faça login na sua assinatura do Azure.

  2. Para enviar o trabalho para o Azure, vá ao editor de consultas e selecione Enviar para o Azure.

  3. Uma janela pop-up é aberta. Escolha atualizar um trabalho existente no Stream Analytics Edge ou criar um novo. Quando você atualiza um trabalho existente, ele substitui toda a configuração do trabalho. Nesse cenário, você publica um novo trabalho. Selecione Criar um Novo Trabalho no Azure Stream Analytics, insira um nome para sua vaga, como MyASAEdgeJob, escolha a Assinatura necessária, Grupo de Recursos e Localização, e então selecione Enviar.

    Captura de tela da caixa de diálogo para enviar um trabalho do Stream Analytics Edge para o Azure a partir do Visual Studio.

    Agora você tem um emprego de Stream Analytics Edge. Para aprender como implantá-lo em seus dispositivos, veja Executar trabalhos no IoT Edge.

Gerencie o trabalho

Gerencie o status do trabalho e o diagrama do trabalho pelo Server Explorer.

  1. A partir do Stream Analytics no Gerenciador de Servidores, expanda a assinatura e o grupo de recursos onde você implantou o trabalho do Edge do Stream Analytics. Você vê o MyASAEdgejob com o status Criado. Expanda o nó do trabalho e, em seguida, abra-o para visualizar o trabalho.

    Captura de tela do Server Explorer mostrando opções de gerenciamento de tarefas para um trabalho Stream Analytics Edge.

  2. Na janela de visualização de trabalhos, você pode atualizar o trabalho, excluí-lo e abri-lo no portal do Azure.

    Captura de tela da janela de visualização de trabalhos mostrando o diagrama de trabalhos e outras opções no Visual Studio.

Conteúdo relacionado

  • Last updated on