Skip to main content

PutWebSocket

Описание

Отправляет сообщения на удаленный WebSocket с использованием сессии WebSocket, которая была установлена либо ListenWebSocket, либо ConnectWebSocket.

Теги

WebSocket, publish, send

Свойства

НазваниеОписание
WebSocket Session IdВыражение NiFi для получения идентификатора сеанса. Если не указано, сообщение будет отправлено всем подключенным узлам WebSocket для конечной точки службы контроллера WebSocket. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
WebSocket ControllerService IdВыражение NiFi для получения идентификатора службы контроллера WebSocket. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
WebSocket Endpoint IdВыражение NiFi для получения идентификатора конечной точки службы контроллера WebSocket. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
WebSocket Message TypeТип содержимого сообщения: ТЕКСТ или ДВОИЧНЫЙ Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)

Взаимосвязи

  • success: Файлы потока, успешно отправленные в пункт назначения, передаются по этому каналу связи.
  • failure: Файлы потока, которые не удалось отправить в пункт назначения, передаются по этому каналу связи.