Apache NiFi - Processore personalizzato

Apache NiFi è una piattaforma open source e offre agli sviluppatori la possibilità di aggiungere il proprio processore personalizzato nella libreria NiFi. Segui questi passaggi per creare un processore personalizzato.

Scarica l'ultima versione di Maven dal link indicato di seguito.

https://maven.apache.org/download.cgi
Aggiungi una variabile di ambiente denominata M2_HOME e imposta il valore come directory di installazione di maven.
Scarica Eclipse IDE dal link sottostante.

https://www.eclipse.org/downloads/download.php
Apri il prompt dei comandi ed esegui il comando Maven Archetype.

> mvn archetype:generate

Cerca il tipo nifi nei progetti archetipo.
Seleziona org.apache.nifi: nifi-processor-bundle-archetype project.
Quindi dall'elenco delle versioni selezionare l'ultima versione, ovvero 1.7.1 per questo tutorial.
Immettere groupId, artifactId, versione, pacchetto e artifactBaseName ecc.
Quindi verrà creato un progetto Maven con directory.
- nifi-<artifactBaseName>-processors
- nifi-<artifactBaseName>-nar
Esegui il comando seguente nella directory nifi- <artifactBaseName> -processors per aggiungere il progetto in eclipse.

mvn install eclipse:eclipse

Apri eclipse e seleziona importa dal menu file.
Quindi seleziona "Progetti esistenti nello spazio di lavoro" e aggiungi il progetto dalla directory nifi- <artifactBaseName> -processors in eclipse.
Aggiungi il tuo codice nella funzione public void onTrigger (contesto ProcessContext, sessione ProcessSession), che viene eseguita ogni volta che è pianificata l'esecuzione di un processore.
Quindi impacchetta il codice in un file NAR eseguendo il comando indicato di seguito.

mvn clean install

Un file NAR verrà creato su nifi- -nar / directory di destinazione.
Copia il file NAR nella cartella lib di Apache NiFi e riavvia NiFi.
Dopo il corretto riavvio di NiFi, controllare l'elenco dei processori per il nuovo processore personalizzato.
Per eventuali errori, controlla il file ./logs/nifi.log.