ConnectWebSocket 2025.5.31.15¶

Bundle¶

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

Beschreibung¶

Dient als WebSocket-Client-Endpunkt zur Interaktion mit einem Remote-WebSocket-Server. FlowFiles werden entsprechend den empfangenen Meldungstypen an nachgelagerte Beziehungen übertragen, wenn der mit diesem Prozessor konfigurierte WebSocket-Client Meldungen vom Remote-WebSocket-Server empfängt. Wenn ein neues FlowFile an den Prozessor übergeben wird, werden die vorherigen Sitzungen geschlossen und alle Datenübertragungen abgebrochen.

Tags¶

WebSocket, verarbeiten, lauschen, abonnieren

Eingabeanforderung¶

ALLOWED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
websocket-client-controller-service	Ein WebSocket CLIENT-Controller Service, der eine Verbindung zu einem WebSocket-Server herstellen kann.
websocket-client-id	Die Client-ID zur Identifizierung der WebSocket-Sitzung. Sie sollte innerhalb des WebSocket Client-Controller Service eindeutig sein. Andernfalls wird beim Start eine WebSocketConfigurationException ausgegeben.

Beziehungen¶

Name	Beschreibung
binary message	Die binäre WebSocket-Meldungsausgabe
connected	Die WebSocket-Sitzung wird aufgebaut.
disconnected	Die WebSocket-Sitzung wird getrennt.
failure	FlowFile, das Konfigurationsattribute für die Verbindung (wie URL oder HTTP-Header) enthält, falls die Verbindung fehlschlägt.
success	FlowFile, das Konfigurationsattribute für die Verbindung (wie URL oder HTTP-Header) enthält, falls die Verbindung erfolgreich ist.
text message	Die WebSocket-Textmeldungsausgabe

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.local.address	WebSocket-Clientadresse
websocket.remote.adresse	WebSocket-Serveradresse.
websocket.message.type	TEXT oder BINARY.