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.
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.
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.