ListenUDPRecord 2025.10.9.21¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Detecta pacotes de datagramas em determinar porta e lê o conteúdo de cada datagrama usando o Record Reader configurado. Cada registro será então gravado em um arquivo de fluxo usando o Record Writer configurado. Esse processador pode ser restrito a detectar datagramas de um host remoto e porta específicos, especificando as propriedades Host de envio e Porta do host de envio. Caso contrário, ele detectará datagramas de todos os hosts e portas.
Requisito de entrada¶
FORBIDDEN
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Conjunto de caracteres |
Especifica o conjunto de caracteres dos dados recebidos. |
Interface de rede local |
O nome de uma interface de rede local a ser usada para restringir a escuta de uma LAN específica. |
Tamanho máximo da fila de mensagens |
O tamanho máximo da fila interna usada para armazenar em buffer as mensagens que estão sendo transferidas do canal subjacente para o processador. Definir esse valor mais alto permite que mais mensagens sejam armazenadas em buffer na memória durante picos de mensagens recebidas, mas aumenta a memória total usada pelo processador. |
Tamanho máximo do buffer do soquete |
O tamanho máximo do buffer do soquete que deve ser usado. Essa é uma sugestão para o sistema operacional para indicar o tamanho do buffer do soquete. Se esse valor for definido como muito baixo, o buffer poderá se encher antes que os dados possam ser lidos, e os dados recebidos serão descartados. |
Porta |
A porta de escuta para comunicação. |
Tamanho do buffer de recepção |
O tamanho de cada buffer usado para receber mensagens. Ajuste esse valor adequadamente com base no tamanho esperado das mensagens recebidas. |
batch-size |
O número máximo de datagramas a serem gravados como registros em um único FlowFile. O Tamanho do lote só será atingido quando os dados estiverem chegando com mais frequência do que o Tempo limito de pesquisa. |
poll-timeout |
O tempo de espera ao consultar a fila interna para obter mais datagramas. Se nenhum datagrama for encontrado depois de aguardar o tempo limite configurado, o processador emitirá todos os registros obtidos até aquele momento. |
record-reader |
O Record Reader a ser usado para ler o conteúdo dos datagramas recebidos. |
record-writer |
O Record Writer a ser usado para serializar os dados antes de gravar em um FlowFile. |
sending-host |
IP ou nome de um host remoto. Somente os datagramas da porta do host de origem especificada e desse host serão aceitos. Melhora o desempenho. Pode ser uma propriedade do sistema ou uma variável de ambiente. |
sending-host-port |
Porta que está sendo usada pelo host remoto para enviar datagramas. Somente os datagramas do host de origem especificado e dessa porta serão aceitos. Melhora o desempenho. Pode ser uma propriedade do sistema ou uma variável de ambiente. |
Relações¶
Nome |
Descrição |
|---|---|
parse.failure |
Se um datagrama não puder ser analisado usando o Record Reader configurado, o conteúdo da mensagem será encaminhado para essa relação como seu próprio FlowFile. |
success |
As mensagens recebidas com sucesso serão enviadas para essa relação. |
Grava atributos¶
Nome |
Descrição |
|---|---|
udp.sender |
O host de origem das mensagens. |
udp.port |
A porta de envio em que as mensagens foram recebidas. |
record.count |
O número de registros gravados no FlowFile. |
mime.type |
O tipo MIME do gravador usado para gravar os registros no FlowFile. |