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.

Tags

WebSocket, veröffentlichen, senden

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.