Apache NiFi - relacionamento de processadores

Em um fluxo de dados Apache NiFi, os arquivos de fluxo se movem de um processador para outro por meio de uma conexão que é validada usando um relacionamento entre os processadores. Sempre que uma conexão é criada, um desenvolvedor seleciona um ou mais relacionamentos entre esses processadores.

Como você pode ver na imagem acima, as caixas de seleção no retângulo preto são relacionamentos. Se um desenvolvedor selecionar essas caixas de seleção, o arquivo de fluxo será encerrado nesse processador específico, quando o relacionamento for de sucesso ou falha ou ambos.

Sucesso

Quando um processador processa com sucesso um arquivo de fluxo como armazenar ou buscar dados de qualquer fonte de dados sem obter nenhuma conexão, autenticação ou qualquer outro erro, então o arquivo de fluxo vai para o relacionamento de sucesso.

Falha

Quando um processador não consegue processar um arquivo de fluxo sem erros, como erro de autenticação ou problema de conexão, etc., o arquivo de fluxo entra em um relacionamento de falha.

Um desenvolvedor também pode transferir os arquivos de fluxo para outros processadores usando conexões. O desenvolvedor pode selecionar e também balancear a carga, mas o balanceamento de carga acabou de ser lançado na versão 1.8, que não será abordada neste tutorial.

Como você pode ver na imagem acima, a conexão marcada em vermelho tem relacionamento de falha, o que significa que todos os arquivos de fluxo com erros irão para o processador à esquerda e respectivamente todos os arquivos de fluxo sem erros serão transferidos para a conexão marcada em verde.

Vamos agora prosseguir com os outros relacionamentos.

comms.failure

Esse relacionamento é atendido quando um Flowfile não pode ser obtido do servidor remoto devido a uma falha de comunicação.

não encontrado

Qualquer arquivo de fluxo para o qual recebemos uma mensagem 'Não encontrado' do servidor remoto irá mover not.found relação.

permissão negada

Quando o NiFi não consegue buscar um arquivo de fluxo do servidor remoto devido a permissão insuficiente, ele se moverá por esse relacionamento.