Desenvolver tarefas do Stream Analytics Edge com ferramentas do Visual Studio

Neste tutorial, vai aprender a utilizar as ferramentas do Stream Analytics para o Visual Studio. Vai aprender a criar, depurar e criar as suas tarefas do Stream Analytics Edge. Depois de criar e testar a tarefa, pode aceder ao portal do Azure para implementá-lo nos seus dispositivos.

Pré-requisitos

Precisa dos seguintes pré-requisitos para concluir este tutorial:

Criar um projeto do Stream Analytics Edge

No Visual Studio, selecione Ficheiro>Novo>Projeto. Navegue para a lista Modelos à esquerda>, expanda Aplicação Edge do Azure Stream Analytics>Edge> doAzure Stream Analytics. Forneça um Nome, Localização e Nome da solução para o projeto e selecione OK.

Novo projeto do Stream Analytics Edge no Visual Studio

Após a criação do projeto, navegue para o Explorador de Soluções para ver a hierarquia de pastas.

Vista do explorador de soluções da tarefa do Stream Analytics Edge

Escolher a subscrição correta

  1. No menu Vista do Visual Studio, selecione Explorador de Servidores.

  2. Clique com o botão direito do rato no Azure> Selecione Ligar à Subscrição do> Microsoft Azure e, em seguida, inicie sessão com a sua conta do Azure.

Definir entradas

  1. A partir do Explorador de Soluções, expanda o nó Inputs (Entradas) que deverá ver uma entrada com o nome EdgeInput.json. Faça duplo clique para ver as definições.

  2. Defina Tipo de Origem como Fluxo de Dados. Em seguida, defina Origem como Hub do Edge, Formato de Serialização de Eventos como Json e Codificação para UTF8. Opcionalmente, pode mudar o nome do Alias de Entrada. Vamos deixá-lo como está neste exemplo. Caso mude o nome do alias de entrada, utilize o nome que especificou ao definir a consulta. Selecione Guardar para guardar as definições.
    Configuração de entrada da tarefa do Stream Analytics

Definir saídas

  1. A partir do Explorador de Soluções, expanda o nó Saídas que deverá ver uma saída com o nome EdgeOutput.json. Faça duplo clique para ver as definições.

  2. Certifique-se de que define Sink para selecionar Hub edge, defina Formato de Serialização de Eventos como Json, defina Codificação como UTF8 e defina Formatar Matriz. Opcionalmente, pode mudar o nome do Alias de Saída. Vamos deixá-lo como está neste exemplo. Caso mude o nome do alias de saída, utilize o nome que especificou ao definir a consulta. Selecione Guardar para guardar as definições. Configuração da saída da tarefa do Stream Analytics

Definir a consulta de transformação

As tarefas do Stream Analytics implementadas nos ambientes de IoT Edge do Stream Analytics suportam a maior parte da referência da Linguagem de Consulta do Stream Analytics. No entanto, as seguintes operações ainda não são suportadas para tarefas do Stream Analytics Edge:

Categoria Comando
Outros operadores
  • PARTIÇÃO POR
  • CARIMBO DE DATA/HORA EXCEDIDO
  • UDF em JavaScript
  • Agregados definidos pelo utilizador (UDA)
  • GetMetadataPropertyValue
  • Utilizar mais de 14 agregados num único passo

Quando cria uma tarefa do Stream Analytics Edge no portal, o compilador avisa-o automaticamente se não estiver a utilizar um operador suportado.

No Visual Studio, defina a seguinte consulta de transformação no editor de consultas (ficheiro script.asaql)

SELECT * INTO EdgeOutput
FROM EdgeInput 

Testar a tarefa localmente

Para testar a consulta localmente, deve carregar os dados de exemplo. Pode obter dados de exemplo ao transferir dados de registo do repositório do GitHub e guardá-lo no seu computador local.

  1. Para carregar dados de exemplo, clique com o botão direito do rato no ficheiro EdgeInput.json e selecione Adicionar Entrada Local

  2. Na janela > de pop-up, procure os dados de exemplo a partir do caminho > local Selecione Guardar. Configuração de entrada local no Visual Studio

  3. É adicionado automaticamente um ficheiro com o nome local_EdgeInput.json à pasta inputs.

  4. Pode executá-lo localmente ou submeter para o Azure. Para testar a consulta, selecione Executar Localmente.
    Opções de execução de tarefas do Stream Analytics no Visual Studio

  5. A janela da linha de comandos mostra o estado da tarefa. Quando a tarefa é executada com êxito, cria uma pasta com o aspeto "2018-02-23-11-31-42" no caminho da pasta do projeto "Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42". Navegue para o caminho da pasta para ver os resultados na pasta local:

    Também pode iniciar sessão no portal do Azure e verificar se a tarefa foi criada.

    Pasta de resultados da tarefa do Stream Analytics

Submeter a tarefa para o Azure

  1. Antes de submeter a tarefa para o Azure, tem de se ligar à sua Subscrição do Azure. Abra o Explorador de Servidores> com o botão direito do rato no Azure>Connect para a subscrição> do Microsoft Azure iniciar sessão na sua subscrição do Azure.

  2. Para submeter a tarefa para o Azure, navegue para o editor > de consultas, selecione Submeter para o Azure.

  3. É aberta uma janela de pop-up. Opte por atualizar uma tarefa existente do Stream Analytics Edge ou criar uma nova. Quando atualiza uma tarefa existente, esta irá substituir toda a configuração da tarefa, neste cenário, irá publicar uma nova tarefa. Selecione Criar uma Nova Tarefa> do Azure Stream Analytics introduza um nome para a sua tarefa, algo como MyASAEdgeJob> , escolha a Subscrição necessária, Grupo de Recursos e Localização> Selecionar Submeter.

    Submeter a tarefa do Stream Analytics para o Azure a partir do Visual Studio

    Agora que a sua tarefa do Stream Analytics Edge foi criada. Pode consultar o tutorial Executar tarefas no IoT Edge para saber como implementá-lo nos seus dispositivos.

Gerir a tarefa

Pode ver o estado da tarefa e o diagrama da tarefa a partir do Explorador de Servidores. A partir do Stream Analytics no Explorador de Servidores, expanda a subscrição e o grupo de recursos onde implementou a tarefa do Stream Analytics Edge. Pode ver o MyASAEdgejob com o estado Criado. Expanda o nó da tarefa e faça duplo clique no mesmo para abrir a vista de trabalho.

Opções de gestão de tarefas do explorador de servidores

A janela da vista de trabalho fornece-lhe operações como atualizar a tarefa, eliminar a tarefa e abrir a tarefa a partir de portal do Azure.

Diagrama de tarefas e outras opções no Visual Studio

Passos seguintes