PutWebSocket 2025.5.31.15

Pacote

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

Descrição

Envia mensagens para um ponto de extremidade remoto WebSocket usando uma sessão WebSocket estabelecida por ListenWebSocket ou ConnectWebSocket.

Tags

WebSocket, publicar, enviar

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

websocket-controller-service-id

Uma expressão NiFi para recuperar o ID de um WebSocket ControllerService.

websocket-endpoint-id

Uma expressão NiFi para recuperar o ID do ponto de extremidade de um WebSocket ControllerService.

websocket-message-type

O tipo de conteúdo da mensagem: TEXT ou BINARY

websocket-session-id

Uma expressão NiFi para recuperar o ID da sessão. Se não for especificada, uma mensagem será enviada a todos os pares conectados no WebSocket para o ponto de extremidade do serviço de controlador do WebSocket.

Relações

Nome

Descrição

failure

FlowFiles que não foram enviados ao destino são transferidos para essa relação.

success

FlowFiles enviados com sucesso para o destino são transferidos para essa relação.

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.message.type

TEXT ou BINARY.

websocket.local.address

Endereço do servidor WebSocket

websocket.remote.address

Endereço do cliente WebSocket

websocket.failure.detail

Detalhe da falha.