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.