ConnectWebSocket 2025.5.31.15¶

Bundle¶

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

Description¶

Joue le rôle de point de terminaison de client WebSocket pour interagir avec un serveur WebSocket distant. Des FlowFiles sont transférés aux relations en aval en fonction des types de messages reçus lorsque le client WebSocket configuré avec ce processeur reçoit des messages du serveur WebSocket distant. Si un nouveau FlowFile est transmis au processeur, les sessions précédentes seront fermées et tous les envois de données en cours seront interrompus.

Balises¶

WebSocket, consommer, écouter, s’abonner

Exigences en matière d’entrées¶

ALLOWED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
websocket-client-controller-service	Un Controller Service CLIENT WebSocket qui peut se connecter à un serveur WebSocket.
websocket-client-id	L’ID de client servant à identifier la session WebSocket. Celui-ci doit être unique au sein du Controller Service client WebSocket. Sinon, il envoie une exception WebSocketConfigurationException lors de son démarrage.

Relations¶

Nom	Description
binary message	La sortie de message binaire WebSocket
connected	La session WebSocket est établie
disconnected	La session WebSocket est déconnectée
failure	FlowFile conservant les attributs de configuration de la connexion (comme l’URL ou les en-têtes HTTP) dans l’éventualité d’un échec de la connexion
success	FlowFile conservant les attributs de configuration de la connexion (comme l’URL ou les en-têtes HTTP) en cas de connexion réussie
message texte	La sortie de message texte WebSocket

É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.local.address	Adresse du client WebSocket.
websocket.remote.address	Adresse du serveur WebSocket.
websocket.message.type	TEXT ou BINARY.