PutWebSocket 2025.5.31.15

Bundle

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

Description

Envoi de messages à un point de terminaison distant WebSocket à l’aide d’une session WebSocket établie par ListenWebSocket ou ConnectWebSocket.

Balises

WebSocket, publier, envoyer

Exigences en matière d’entrées

REQUIRED

Prend en charge les propriétés dynamiques sensibles

false

Propriétés

Propriété

Description

websocket-controller-service-id

Une expression NiFi pour récupérer l’identifiant d’un WebSocket ControllerService.

websocket-endpoint-id

Une expression NiFi pour récupérer le point de terminaison d’un WebSocket ControllerService.

websocket-message-type

Le type de contenu du message : TEXT ou BINARY

websocket-session-id

Une expression NiFi pour récupérer l’identifiant de la session. S’il n’est pas spécifié, un message sera envoyé à tous les homologues WebSocket connectés pour le point terminaison du Controller Service WebSocket.

Relations

Nom

Description

failure

FlowFiles qui n’ont pas été envoyés à la destination sont transférés à cette relation.

success

FlowFiles qui sont envoyées avec succès à la destination sont transférées à cette relation.

Écrit les attributs

Nom

Description

websocket.controller.service.id

Identifiant du Controller Service WebSocket.

websocket.session.id

Identifiant de la session WebSocket établie.

websocket.endpoint.id

Identifiant du point de terminaison WebSocket.

websocket.message.type

TEXT ou BINARY.

websocket.local.address

Adresse du serveur WebSocket.

websocket.remote.address

Adresse du client WebSocket.

websocket.failure.detail

Détail de l’échec.