Compartilhar via


Materializar dados no Azure Cosmos DB usando o editor sem código do Stream Analytics

Este artigo descreve como você pode usar o editor sem código para criar um trabalho do Stream Analytics com facilidade. O trabalho lê continuamente de seus Hubs de Eventos e executa agregações como contagem, soma e média. Você seleciona campos a serem agrupados ao longo de uma janela de tempo e, em seguida, o trabalho grava os resultados continuamente no Azure Cosmos DB.

Pré-requisitos

  • Os recursos dos Hubs de Eventos do Azure e do Azure Cosmos DB precisam ser acessíveis publicamente e não podem estar protegidos por um firewall ou em uma Rede Virtual do Azure.
  • Os dados nos Hubs de Eventos precisam ser serializados no formato JSON, CSV ou Avro.

Desenvolver um trabalho do Stream Analytics

Use as etapas a seguir para desenvolver um trabalho do Stream Analytics a fim de materializar dados no Azure Cosmos DB.

  1. No portal do Azure, localize e selecione a instância dos Hubs de Eventos do Azure.
  2. Em Recursos, selecione Processar dados. Em seguida, selecione Iniciar no cartão intitulado Materializar Dados no Azure Cosmos DB.
    Captura de tela que mostra o fluxo de dados de
  3. Insira um nome para o trabalho e selecione Criar.
  4. Especifique o tipo de Serialização dos dados na janela dos Hubs de Eventos e o Método de autenticação que o trabalho usará para se conectar aos Hubs de Eventos. Depois, selecione Conectar.
  5. Se a conexão for estabelecida com êxito e você tiver fluxos de dados para a instância dos Hubs de Eventos, você verá duas coisas imediatamente:
    • Os campos presentes no conteúdo de entrada. Selecione o símbolo de três pontos ao lado de um campo para opcionalmente remover, renomear ou alterar o tipo de dados do campo.
      Captura de tela que mostra os campos de entrada do hub de eventos a serem revisados por você.
    • Um exemplo de seus dados de entrada no painel inferior na Visualização de dados que é atualizado automaticamente periodicamente. Você pode selecionar Pausar a visualização de streaming se preferir ter uma exibição estática dos dados de entrada de exemplo.
      Captura de tela que mostra dados de entrada de exemplo.
  6. Na próxima etapa, você especifica o campo e a agregação que deseja calcular, como Média e Contagem. Você também pode especificar o campo que deseja para Agrupar Por junto com a janela de tempo. Em seguida, você pode validar os resultados da etapa na seção Visualização de dados.
    Captura de tela que mostra a área Agrupar Por.
  7. Escolha o Banco de dados do Cosmos DB e o contêiner em que você deseja que os resultados sejam gravados.
  8. Inicie o trabalho do Stream Analytics selecionando Iniciar.
    Captura de tela que mostra a definição onde você seleciona Iniciar.
    Para iniciar o trabalho, você precisa especificar:
    • O número de SUs (unidades de streaming) com as quais o trabalho é executado. As SUs representam a quantidade de computação e memória alocada para o trabalho. É recomendável começar com três e ajustar conforme necessário.
    • O tratamento de erros de dados de saída permite que você especifique o comportamento desejado quando a saída de um trabalho para seu destino falhar devido a erros de dados. Por padrão, seu trabalho tenta novamente até que a operação de gravação seja bem-sucedida. Você também pode optar por remover eventos de saída.
  9. Depois de selecionar Iniciar, o trabalho começará a ser executado em até dois minutos. Exiba o trabalho na seção Processar Dados na guia Trabalhos do Stream Analytics. Você pode explorar métricas de trabalho e interrompê-lo e reiniciá-lo, conforme necessário.

Próximas etapas

Agora você sabe como usar o editor sem código do Stream Analytics para desenvolver um trabalho que lê dos Hubs de Eventos e calcula agregações, como contagens e médias e grava-os no recurso do Azure Cosmos DB.