Testando a consulta do Stream Analytics localmente em relação à entrada de transmissão ao vivo com o Visual Studio Code

Testar sua consulta do Stream Analytics localmente em relação à entrada de transmissão ao vivo é uma etapa crucial para garantir a precisão e a eficiência da lógica da consulta. Com a extensão do Azure Stream Analytics (ASA) para Visual Studio Code (VS Code), você tem as ferramentas necessárias para executar esse teste perfeitamente. Este artigo orienta você pelas etapas de configuração do ambiente, configuração da entrada de transmissão ao vivo e execução da consulta localmente para testes completos.

Pré-requisitos

• Instale o SDK do .NET Core e reinicie o Visual Studio Code.
• Siga este início rápido para instalar e criar um trabalho do Stream Analytics usando o Visual Studio Code.

Definir uma entrada de transmissão ao vivo

1. Clique com o botão direito do mouse na pasta Inputs em seu projeto do Stream Analytics e selecione ASA: Add Input. OU pressione Ctrl+Shift+P para abrir a paleta de comandos e digite ASA: Add Input. Em seguida, escolha o script de consulta para processar o fluxo de entrada.

2. Escolha um tipo de fonte de entrada em tempo real na lista suspensa, selecione em suas Assinaturas do Azure e insira um nome para a fonte de entrada.

3. Você verá um novo arquivo JSON criado na pasta Entrada . Abra o arquivo e selecione entre suas assinaturas para ajudá-lo a configurar a entrada dos Hubs de Eventos.

4. Selecione Visualizar dados para validar se a entrada ao vivo foi configurada com êxito.

Executar consulta localmente

Abra o arquivo de consulta, selecione Executar localmente ou o botão Reproduzir na barra de menus para abrir uma janela de opção Execução local para configurar o modo de execução local.

Escolha Usar entrada ao vivo e saída local para executar o trabalho localmente em relação ao fluxo de entrada ao vivo e produzir resultados de saída para uma pasta local. Em seguida, selecione Executar para começar a executar o trabalho localmente.

Você pode ver uma janela de teste local é aberta e atualizada a cada 3 segundos. Os resultados de saída são armazenados como formato JSON na pasta LocalRunOutputs .

Especificar partições de entrada para teste local

Para evitar a ingestão de todos os dados dos Hubs de Eventos, você pode especificar partições específicas para os Hubs de Eventos durante os testes locais.

1. Selecione Executar localmente para abrir a janela de opção de execução local.
2. Em Selecione a seção de partições de entrada e escolha Personalizado.
3. Insira os números de partição específicos dos quais você deseja ingerir dados para seu teste local.

Ao especificar as partições, você pode se concentrar em testar sua lógica de consulta sem se preocupar com um grande volume de dados. Esse recurso permite testes mais eficientes e direcionados do seu trabalho do Stream Analytics.

Enviar trabalho para o Azure

Depois de concluir o teste de sua consulta localmente, você pode enviar seu projeto do Stream Analytics para o Azure e começar a executar o trabalho na nuvem.

1. Selecione a opção Enviar para o Azure ou selecione o botão Carregar no arquivo de consulta.
2. Na janela de opções de envio, você pode atualizar um trabalho existente no Azure ou criar um novo trabalho para o carregamento.
3. Forneça os detalhes necessários, incluindo sua assinatura, grupo de recursos e região para a implantação.

Quando o processo de envio estiver concluído, você poderá visualizar seu trabalho na nuvem em uma nova janela. A partir daí, você pode monitorar seu desempenho e gerenciar suas configurações conforme necessário. Você também pode abrir a vaga em seu navegador clicando no link fornecido no painel SAÍDA.

Próximos passos

• Exportar e gerenciar trabalhos do Stream Analytics usando a extensão de código do Visual Studio
• Visão geral da execução de trabalhos do Stream Analytics localmente
• Testar consultas do Stream Analytics localmente com dados de exemplo
• Configurar pipelines de CI/CD usando o pacote ASA npm