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