PutWebSocket 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-websocket-processors-nar
Beschreibung¶
Sendet Meldungen an einen WebSocket-Remote-Endpunkt unter Verwendung einer WebSocket-Sitzung, die entweder von ListenWebSocket oder ConnectWebSocket aufgebaut wird.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
---|---|
websocket-controller-service-id |
Ein NiFi Ausdruck zum Abrufen der ID einer WebSocket ControllerService. |
websocket-endpoint-id |
Ein NiFi-Ausdruck, um die Endpunkt-ID eines WebSocket ControllerService abzurufen. |
websocket-message-type |
Die Art des Meldungsinhalts: TEXT oder BINARY |
websocket-session-id |
Ein NiFi-Ausdruck, um die Sitzungs-ID abzurufen. Wenn nicht angegeben, wird eine Meldung an alle verbundenen WebSocket-Peers für den WebSocket-Controller-Dienstendpunkt gesendet. |
Beziehungen¶
Name |
Beschreibung |
---|---|
failure |
FlowFiles, die nicht an das Ziel gesendet werden konnten, werden an diese Beziehung übertragen. |
success |
FlowFiles, die erfolgreich an das Ziel gesendet wurden, werden an diese Beziehung übertragen. |
Schreibt Attribute¶
Name |
Beschreibung |
---|---|
websocket.controller.service.id |
WebSocket Controller Service-ID. |
websocket.session.id |
Erstellte WebSocket-Sitzungs-ID. |
websocket.endpoint.id |
WebSocket-Endpunkt-ID. |
websocket.message.type |
TEXT oder BINARY. |
websocket.local.address |
WebSocket-Serveradresse. |
websocket.remote.adresse |
WebSocket-Clientadresse |
websocket.failure.detail |
Detail des Fehlers. |