Перейти к основному содержимому

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: Файлы потока, которые не удалось отправить в пункт назначения, передаются по этому каналу связи.