PutWebSocket 2025.5.31.15¶

捆绑包¶

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

描述¶

使用由 ListenWebSocket 或 ConnectWebSocket 建立的 WebSocket 会话向 WebSocket 远程端点发送消息。

标签¶

WebSocket、publish、send

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
websocket-controller-service-id	用于检索 WebSocket ControllerService 的 ID 的 NiFi 表达式。
websocket-endpoint-id	用于检索 WebSocket ControllerService 的端点 ID 的 NiFi 表达式。
websocket-message-type	消息内容的类型：TEXT 或 BINARY
websocket-session-id	用于检索会话 ID 的 NiFi 表达式。如果未指定，则将向 WebSocket 控制器服务端点的所有已连接 WebSocket 对等方发送消息。

关系¶

名称	描述
failure	未能发送到目标的 FlowFiles 将转移到此关系。
success	成功发送到目标的 FlowFiles 将转移到此关系。

写入属性¶

名称	描述
websocket.controller.service.id	WebSocket 控制器服务 ID。
websocket.session.id	已建立的 WebSocket 会话 ID。
websocket.endpoint.id	WebSocket 端点 ID。
websocket.message.type	TEXT 或 BINARY。
websocket.local.address	WebSocket 服务器地址。
websocket.remote.address	WebSocket 客户端地址。
websocket.failure.detail	失败的详细信息。