ConnectWebSocket 2025.5.31.15¶

Pacote¶

org.apache.nifi | nifi-websocket-processors-nar

Descrição¶

Atua como um ponto de extremidade do cliente WebSocket para interagir com um servidor WebSocket remoto. FlowFiles são transferidos para relacionamentos downstream de acordo com os tipos de mensagens recebidas, pois o cliente WebSocket configurado com esse processador recebe mensagens do servidor WebSocket remoto. Se um novo FlowFile for passado ao processador, as sessões anteriores serão fechadas e todos os dados que estiverem sendo enviados serão abortados.

Tags¶

WebSocket, consumir, ouvir, assinar

Requisito de entrada¶

ALLOWED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
websocket-client-controller-service	Um Controller Service WebSocket CLIENT que pode se conectar a um servidor WebSocket.
websocket-client-id	O ID de cliente para identificar a sessão WebSocket. Ele deve ser exclusivo dentro do Controller Service do cliente WebSocket. Caso contrário, ele gera uma WebSocketConfigurationException quando é iniciado.

Relações¶

Nome	Descrição
binary message	A saída da mensagem binária WebSocket
connected	A sessão WebSocket é estabelecida
disconnected	A sessão WebSocket foi desconectada
failure	FlowFile mantendo os atributos de configuração da conexão (como cabeçalhos URL ou HTTP) em caso de falha na conexão
success	FlowFile mantendo os atributos de configuração da conexão (como cabeçalhos URL ou HTTP) no caso de uma conexão bem-sucedida
text message	A saída da mensagem de texto WebSocket

Grava atributos¶

Nome	Descrição
websocket.controller.service.id	ID do Controller Service WebSocket
websocket.session.id	ID de sessão WebSocket estabelecido
websocket.endpoint.id	ID do ponto de extremidade WebSocket
websocket.local.address	Endereço do cliente WebSocket
websocket.remote.address	Endereço do servidor WebSocket
websocket.message.type	TEXT ou BINARY.