ConnectWebSocket 2025.5.31.15¶

バンドル¶

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

説明¶

リモートの WebSocket サーバーと対話するための WebSocket クライアントエンドポイントとして動作します。FlowFiles は、このプロセッサーで構成された WebSocket クライアントがリモート WebSocket サーバーからメッセージを受信すると、受信したメッセージタイプに従ってダウンストリーム関係に転送されます。新しいフローファイルがプロセッサーに渡されると、以前のセッションは閉じられ、送信中のデータはすべて中止されます。

タグ¶

WebSocket、消費する、聴く、購読する

入力要件¶

ALLOWED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
websocket-client-controller-service	WebSocket サーバーに接続できる WebSocket CLIENT Controller Service。
websocket-client-id	クライアントは WebSocket セッションを識別子 ID で識別します。WebSocket クライアントController Service内で一意である必要があります。そうしないと、起動時に WebSocketConfigurationException が出ます。

リレーションシップ¶

名前	説明
バイナリメッセージ	WebSocket バイナリメッセージ出力
connected	WebSocket セッションの確立
disconnected	WebSocket セッションは切断されます。
failure	FlowFile 接続失敗時の接続構成属性 (URL や HTTP ヘッダーなど) の保持
success	FlowFile 接続が成功した場合の接続構成属性 (URL や HTTP ヘッダーなど) の保持
テキストメッセージ	WebSocket テキストメッセージ出力

属性の書き込み¶

名前	説明
ウェブソケット.コントローラー.サービス.ID	WebSocket コントローラーサービス ID。
ウェブソケット.セッション.ID	WebSocket セッション ID を確立しました。
ウェブソケット.エンドポイント.ID	WebSocket エンドポイントID。
ウェブソケット.ローカル.アドレス	WebSocket クライアントの住所
ウェブソケット.リモート.アドレス	WebSocket サーバーのアドレスです。
ウェブソケット.メッセージ.タイプ	TEXT または BINARY。