Partilhar via


Enriquecer dados e ingerir no hub de eventos com o Stream Analytics sem editor de código

Este artigo descreve como pode utilizar o editor sem código para criar facilmente uma tarefa do Stream Analytics. Lê continuamente a partir dos Hubs de Eventos, melhora os dados recebidos com dados de referência do SQL e, em seguida, escreve os resultados continuamente no hub de eventos.

Pré-requisitos

  • Os recursos de dados de referência Hubs de Eventos do Azure e SQL têm de estar acessíveis publicamente e não estar protegidos por uma firewall ou protegidos num Rede Virtual do Azure
  • Os dados nos Hubs de Eventos têm de ser serializados no formato JSON, CSV ou Avro.

Desenvolver uma tarefa do Stream Analytics para enriquecer os dados do hub de eventos

  1. No portal do Azure, localize e selecione a instância Hubs de Eventos do Azure.

  2. Selecione Funcionalidades>Processar Dados e, em seguida, selecione Iniciar no cartão Enriquecer dados e ingerir no Hub de Eventos .

    Captura de ecrã a mostrar o cartão Filtrar e ingerir para o ADLS Gen2 onde seleciona Iniciar.

  3. Introduza um nome para a tarefa do Stream Analytics e, em seguida, selecione Criar.

    Captura de ecrã a mostrar onde introduzir um nome de tarefa.

  4. Especifique o tipo de Serialização dos seus dados na janela Hubs de Eventos e o método de Autenticação que a tarefa utilizará para ligar aos Hubs de Eventos. Em seguida, selecione Ligar.
    Captura de ecrã a mostrar a configuração da ligação dos Hubs de Eventos.

  5. Quando a ligação for estabelecida com êxito e tiver fluxos de dados a fluir para a instância dos Hubs de Eventos, verá imediatamente duas coisas:

    • Campos que estão presentes nos dados de entrada. Pode escolher Adicionar campo ou selecionar o símbolo de três pontos junto a um campo para remover, mudar o nome ou alterar o respetivo tipo.
      Captura de ecrã a mostrar a lista de campos dos Hubs de Eventos onde pode remover, mudar o nome ou alterar o tipo de campo.
    • Um exemplo dinâmico de dados recebidos na tabela Pré-visualização de dados na vista de diagrama. Atualiza-se automaticamente periodicamente. Pode selecionar Colocar em pausa a pré-visualização da transmissão em fluxo para ver uma vista estática dos dados de entrada de exemplo.
      Captura de ecrã a mostrar dados de exemplo em Pré-visualização de Dados.
  6. Selecione o mosaico de entrada SQL de referência para ligar à base de dados SQL de referência.
    Captura de ecrã que mostra a configuração da ligação de dados de referência sql.

  7. Selecione o mosaico Associar . No painel de configuração à direita, selecione um campo de cada entrada para associar os dados recebidos das duas entradas.

    Captura de ecrã que mostra a configuração do operador de associação.

  8. Selecione o mosaico Gerir . No painel De configuração Gerir campos , selecione os campos que pretende exportar para o hub de eventos. Se quiser adicionar todos os campos, selecione Adicionar todos os campos.

    Captura de ecrã que mostra a configuração do operador de campo gerir.

  9. Selecione o mosaico Hub de Eventos . No painel de configuração do Hub de Eventos , preencha os parâmetros necessários e ligue-se, de forma semelhante à configuração do hub de eventos de entrada.

  10. Opcionalmente, selecione Obter pré-visualização estática/Atualizar pré-visualização estática para ver a pré-visualização de dados que será ingerida no hub de eventos.
    Captura de ecrã a mostrar a opção Obter pré-visualização estática/Atualizar pré-visualização estática.

  11. Selecione Guardar e, em seguida, selecione Iniciar a tarefa do Stream Analytics.
    Captura de ecrã a mostrar as opções Guardar e Iniciar.

  12. Para iniciar a tarefa, especifique:

    • O número de Unidades de Transmissão em Fluxo (SUs) com que a tarefa é executada. As SUs representam a quantidade de computação e memória alocadas à tarefa. Recomendamos que comece com três e, em seguida, ajuste conforme necessário.
    • Processamento de erros de dados de saída – permite-lhe especificar o comportamento que pretende quando a saída de uma tarefa para o seu destino falha devido a erros de dados. Por predefinição, a tarefa é novamente executada até que a operação de escrita seja bem-sucedida. Também pode optar por remover esses eventos de saída.
      Captura de ecrã a mostrar as opções de tarefa iniciar o Stream Analytics onde pode alterar a hora de saída, definir o número de unidades de transmissão em fluxo e selecionar as opções de processamento de erros de dados de saída.
  13. Depois de selecionar Iniciar, a tarefa começa a ser executada dentro de dois minutos e as métricas serão abertas na secção de separadores abaixo.

    Captura de ecrã que mostra os dados das métricas da tarefa após a sua introdução.

    Também pode ver a tarefa na secção Dados do Processo no separador Tarefas do Stream Analytics . Selecione Abrir métricas para monitorizá-lo ou parar e reiniciá-lo, conforme necessário.

    Captura de ecrã do separador Tarefas do Stream Analytics onde vê o estado das tarefas em execução.

Passos seguintes

Saiba mais sobre o Azure Stream Analytics e como monitorizar a tarefa que criou.