Apache NiFi - Processador Personalizado

Apache NiFi é uma plataforma de código aberto e oferece aos desenvolvedores a opção de adicionar seu processador personalizado à biblioteca NiFi. Siga estas etapas para criar um processador personalizado.

• Baixe a versão mais recente do Maven no link fornecido a seguir.

  https://maven.apache.org/download.cgi

• Adicione uma variável de ambiente chamada M2_HOME e defina o valor como o diretório de instalação do maven.

• Faça download do Eclipse IDE no link abaixo.

  https://www.eclipse.org/downloads/download.php

• Abra o prompt de comando e execute o comando Maven Archetype.

> mvn archetype:generate

• Pesquise o tipo nifi nos projetos de arquétipo.

• Selecione org.apache.nifi: projeto nifi-processor-bundle-archetype.

• Em seguida, na lista de versões, selecione a versão mais recente, ou seja, 1.7.1 para este tutorial.

• Insira groupId, artifactId, versão, pacote e artifactBaseName etc.

• Em seguida, um projeto maven será criado tendo como diretórios.

  • nifi-<artifactBaseName>-processors

  • nifi-<artifactBaseName>-nar

• Execute o comando abaixo no diretório nifi- <artifactBaseName> -processors para adicionar o projeto no eclipse.

mvn install eclipse:eclipse

• Abra o eclipse e selecione importar no menu de arquivo.

• Em seguida, selecione “Projetos Existentes no espaço de trabalho” e adicione o projeto do diretório nifi- <artifactBaseName> -processors no eclipse.

• Adicione seu código na função pública void onTrigger (ProcessContext context, ProcessSession session), que é executada sempre que um processador está programado para ser executado.

• Em seguida, empacote o código em um arquivo NAR executando o comando mencionado abaixo.

mvn clean install

• Um arquivo NAR será criado no nifi- -nar / diretório de destino.

• Copie o arquivo NAR para a pasta lib do Apache NiFi e reinicie o NiFi.

• Após o reinício bem-sucedido do NiFi, verifique a lista de processadores para o novo processador personalizado.

• Para quaisquer erros, verifique o arquivo ./logs/nifi.log.