Apache NiFi - Criando Fluxos

O Apache NiFi oferece um grande número de componentes para ajudar os desenvolvedores a criar fluxos de dados para qualquer tipo de protocolo ou fonte de dados. Para criar um fluxo, um desenvolvedor arrasta os componentes da barra de menus para a tela e os conecta clicando e arrastando o mouse de um componente para outro.

Geralmente, uma NiFi tem um componente de escuta no início do fluxo, como getfile, que obtém os dados do sistema de origem. Na outra extremidade, há um componente transmissor como putfile e há componentes intermediários que processam os dados.

Por exemplo, vamos criar um fluxo, que pega um arquivo vazio de um diretório e adiciona algum texto a esse arquivo e o coloca em outro diretório.

• Para começar, arraste o ícone do processador para a tela NiFi e selecione GetFile Processor na lista.

• Crie um diretório de entrada como c:\inputdir.

• Clique com o botão direito no processador e selecione configurar e na guia de propriedades adicionar Input Directory (c:\inputdir) e clique em aplicar e volte para a tela.

• Arraste o ícone do processador para a tela e selecione o processador ReplaceText na lista.

• Clique com o botão direito no processador e selecione configurar. Noproperties guia, adicione algum texto como “Hello tutorialspoint.com” na caixa de texto de Valor de substituição e clique em aplicar.

• Vá para a guia de configurações, marque a caixa de seleção de falha no lado direito e volte para a tela.

• Conecte o processador GetFIle ao ReplaceText no relacionamento de sucesso.

• Arraste o ícone do processador para a tela e selecione o processador PutFile na lista.

• Crie um diretório de saída como c:\outputdir.

• Clique com o botão direito no processador e selecione configurar. Na guia de propriedades, adicioneDirectory (c:\outputdir) e clique em aplicar e volte para a tela.

• Vá para a guia de configurações e marque a caixa de seleção de falha e sucesso no lado direito e volte para a tela.

• Conecte o processador ReplaceText ao PutFile no relacionamento de sucesso.

• Agora inicie o fluxo e adicione um arquivo vazio no diretório de entrada e você verá que, ele irá mover para o diretório de saída e o texto será adicionado ao arquivo.

Seguindo as etapas acima, os desenvolvedores podem escolher qualquer processador e outro componente NiFi para criar um fluxo adequado para sua organização ou cliente.