Apache NiFi - Relazione tra processori

In un flusso di dati NiFi Apache, i file di flusso si spostano da un processore a un altro tramite una connessione che viene convalidata utilizzando una relazione tra i processori. Ogni volta che viene creata una connessione, uno sviluppatore seleziona una o più relazioni tra quei processori.

Come puoi vedere nell'immagine sopra, le caselle di controllo nel rettangolo nero sono relazioni. Se uno sviluppatore seleziona queste caselle di controllo, il file di flusso terminerà in quel particolare processore, quando la relazione ha successo o fallimento o entrambi.

Successo

Quando un processore elabora con successo un file di flusso come memorizzare o recuperare dati da qualsiasi origine dati senza ottenere alcuna connessione, autenticazione o altri errori, il file di flusso passa alla relazione di successo.

Fallimento

Quando un processore non è in grado di elaborare un file di flusso senza errori come errore di autenticazione o problema di connessione, ecc., Il file di flusso passa a una relazione di errore.

Uno sviluppatore può anche trasferire i file di flusso ad altri processori utilizzando le connessioni. Lo sviluppatore può selezionarlo e anche bilanciarlo, ma il bilanciamento del carico è appena stato rilasciato nella versione 1.8, che non verrà trattata in questo tutorial.

Come puoi vedere nell'immagine sopra, la connessione contrassegnata in rosso ha una relazione di errore, il che significa che tutti i file di flusso con errori andranno al processore a sinistra e rispettivamente tutti i file di flusso senza errori verranno trasferiti alla connessione contrassegnata in verde.

Procediamo ora con le altre relazioni.

comms.failure

Questa relazione viene soddisfatta quando non è stato possibile recuperare un file di flusso dal server remoto a causa di un errore di comunicazione.

non trovato

Qualsiasi file di flusso per il quale riceviamo un messaggio "Non trovato" dal server remoto verrà spostato not.found relazione.

permesso negato

Quando NiFi non è in grado di recuperare un file di flusso dal server remoto a causa di un'autorizzazione insufficiente, passerà attraverso questa relazione.