Desenvolva trabalhos de Stream Analytics Edge utilizando ferramentas do Visual Studio

Neste artigo, aprende a utilizar 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, vai ao portal do Azure para o implementar nos seus dispositivos.

Pré-requisitos para desenvolver tarefas no Edge

Precisa dos seguintes pré-requisitos para completar os passos deste artigo:

  1. Instale o Visual Studio 2019, Visual Studio 2015 ou Visual Studio 2013 Atualização 4. As ferramentas de Stream Analytics 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.

Criar um projeto Stream Analytics Edge

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

  1. No Visual Studio, selecione Ficheiro>Novo>Projeto. Aceda à lista Templates à esquerda e, em seguida, expanda Azure Stream Analytics>Stream Analytics Edge>Azure Stream Analytics Edge Application. Introduza um nome, localização e nome da solução para o seu projeto, e depois selecione OK.

    Captura de ecrã da caixa de diálogo New Project para criar uma aplicação Azure Stream Analytics Edge no Visual Studio.

  2. Depois de o Visual Studio criar o projeto, vai ao Explorador de Soluções para ver a hierarquia das pastas.

    Captura de ecrã do Explorador de Soluções a mostrar a hierarquia de pastas de um projeto Stream Analytics Edge no Visual Studio.

Escolha a subscrição correta

Liga o Visual Studio à subscrição do Azure onde queres criar o trabalho.

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

  2. Selecione e mantenha premido (ou clique com o botão direito do rato) Azure, selecione Ligar à subscrição do Microsoft Azure e, em seguida, inicie sessão com a sua conta do Azure.

Definir entradas

Configure a entrada do Edge Hub a partir da qual a tarefa lê os eventos de streaming.

  1. A partir do Explorador de Soluções, expanda o nó Inputs. Vê uma entrada chamada EdgeInput.json. Abra-o para ver as definições.

  2. Defina o tipo de fonte para fluxo de dados. Depois define a fonte para Edge Hub, o formato de serialização de eventos para Json e a codificação para UTF8. Opcionalmente, renomeia o Alias de Entrada, mas deixa-o como está neste exemplo. Se renomear o alias de entrada, use o nome que especificar ao definir a consulta. Selecione Guardar para guardar as definições. Captura de ecrã das definições de configuração de entrada do Stream Analytics Edge Hub no Visual Studio.

Definir saídas

Configure a saída do Edge Hub para a qual a tarefa escreve os resultados.

  1. A partir do Explorador de Soluções, expanda o nó Outputs. Vê uma saída chamada EdgeOutput.json. Abra-o para ver as definições.

  2. Defina o Sink para Edge Hub, defina o Event Serialization Format para Json, defina a codificação para UTF8 e defina o Format para Array. Opcionalmente, renomeia o Alias de Saída, mas deixa-o como está neste exemplo. Se renomeares o alias de saída, usa o nome que especificas quando defines a consulta. Selecione Guardar para guardar as definições. Captura de ecrã das definições de configuração de saída do Stream Analytics Edge Hub no Visual Studio.

Analisar operações não suportadas

Os trabalhos de Stream Analytics implementados nos ambientes Stream Analytics IoT Edge suportam a maior parte da referência da Stream Analytics Query Language. No entanto, as seguintes operações não são suportadas para trabalhos de Stream Analytics Edge:

  1. PARTIÇÃO POR
  2. CARIMBO TEMPORAL POR OVER
  3. JavaScript UDF
  4. Agregados definidos pelo utilizador (UDA)
  5. GetMetadataPropertyValue
  6. Usando mais de 14 agregados num único passo

Quando cria um trabalho Stream Analytics Edge no portal, o compilador avisa-o automaticamente se não estiver a usar 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 ficheiro).

SELECT * INTO EdgeOutput
FROM EdgeInput

Testar a tarefa localmente

Para testar a consulta localmente, carregue os dados de amostra. Para obter dados de exemplo, descarregue os dados de registo do repositório GitHub e guarde-os no seu computador local.

  1. Para carregar dados de exemplo, selecione e mantenha premido o ficheiro EdgeInput.json (ou clique com o botão direito do rato no mesmo) e, em seguida, selecione Adicionar entrada local.

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

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

  3. Visual Studio adiciona automaticamente um ficheiro chamado local_EdgeInput.json à tua pasta de entradas.

  4. Podes executá-lo localmente ou submetê-lo ao Azure. Para testar a consulta, selecione Executar Localmente.

    Captura de ecrã das opções de execução do trabalho do Stream Analytics que mostram Run Locally no Visual Studio.

  5. A janela do prompt de comandos mostra o estado do trabalho. Quando a tarefa é executada com sucesso, cria uma pasta semelhante a 2018-02-23-11-31-42 na pasta do projeto, no caminho Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42. Aceda ao caminho da pasta para ver os resultados na pasta local.

    Também pode iniciar sessão no portal do Azure e verificar se o trabalho foi criado.

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

Submeter o trabalho ao Azure

Depois de testares a consulta, publica o trabalho na tua subscrição do Azure.

  1. Antes de submeter o trabalho ao Azure, ligue-se à sua subscrição do Azure. Abra o Explorador de Servidores, selecione e mantenha pressionado (ou clique com o botão direito) no Azure, selecione Ligar à subscrição do Microsoft Azure e depois inicie sessão na sua subscrição do Azure.

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

  3. Abre-se uma janela pop-up. Escolha atualizar um trabalho existente no Stream Analytics Edge ou criar um novo. Quando atualizas um job existente, ele substitui toda a configuração do job. Neste cenário, publica um novo trabalho. Selecione Criar um Novo Emprego Azure Stream Analytics, insira um nome para o seu trabalho, como MyASAEdgeJob, escolha a Subscrição, Grupo de Recursos e Localização necessários, e depois selecione Submeter.

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

    Agora tens um emprego de Stream Analytics Edge. Para saber como implementá-lo nos seus dispositivos, veja Executar trabalhos no IoT Edge.

Gerir o trabalho

Gerir o estado do trabalho e o diagrama do trabalho a partir do Server Explorer.

  1. Em Stream Analytics, no Server Explorer, expanda a subscrição e o grupo de recursos onde implementou a tarefa do Stream Analytics Edge. Verá MyASAEdgejob com o estado Criado. Expande o nó do teu trabalho e depois abre-o para visualizar o trabalho.

    Captura de ecrã do Server Explorer a mostrar opções de gestão de tarefas para um trabalho Stream Analytics Edge.

  2. Na janela da vista de trabalho, podes atualizar o trabalho, apagá-lo e abri-lo no portal do Azure.

    Captura de ecrã da janela da vista de trabalho a mostrar o diagrama de tarefas e outras opções no Visual Studio.

Conteúdo relacionado

  • Last updated on